org.apache.qpid.server.transport
Class ServerSession
java.lang.Object
org.apache.qpid.transport.SessionInvoker
org.apache.qpid.transport.Session
org.apache.qpid.server.transport.ServerSession
- All Implemented Interfaces:
- ConfiguredObject<SessionConfigType,SessionConfig>, SessionConfig, LogSubject, AMQSessionModel, PrincipalHolder
public class ServerSession
- extends org.apache.qpid.transport.Session
- implements PrincipalHolder, SessionConfig, AMQSessionModel, LogSubject
Nested classes/interfaces inherited from class org.apache.qpid.transport.Session |
org.apache.qpid.transport.Session.State |
Fields inherited from class org.apache.qpid.transport.Session |
UNLIMITED_CREDIT |
Constructor Summary |
ServerSession(org.apache.qpid.transport.Connection connection,
org.apache.qpid.transport.SessionDelegate delegate,
org.apache.qpid.transport.Binary name,
long expiry)
|
ServerSession(org.apache.qpid.transport.Connection connection,
org.apache.qpid.transport.SessionDelegate delegate,
org.apache.qpid.transport.Binary name,
long expiry,
ConnectionConfig connConfig)
|
Methods inherited from class org.apache.qpid.transport.Session |
close, closed, complete, exception, flushProcessed, getChannel, getCommandsIn, getCommandsOut, getConnection, getName, getSessionListener, invoke, invoke, invoke, isBytesFull, isClosing, isCommandsFull, messageTransfer, messageTransfer, nextCommandId, processed, processed, processed, processed, setAutoSync, setSessionListener, shouldIssueFlush, sync, sync, toString |
Methods inherited from class org.apache.qpid.transport.SessionInvoker |
dtxCommit, dtxEnd, dtxForget, dtxGetTimeout, dtxPrepare, dtxRecover, dtxRollback, dtxSelect, dtxSetTimeout, dtxStart, exchangeBind, exchangeBound, exchangeDeclare, exchangeDelete, exchangeQuery, exchangeUnbind, executionException, executionResult, executionSync, messageAccept, messageAcquire, messageCancel, messageFlow, messageFlush, messageReject, messageRelease, messageResume, messageSetFlowMode, messageStop, messageSubscribe, messageTransfer, queueDeclare, queueDelete, queuePurge, queueQuery, txCommit, txRollback, txSelect |
ServerSession
ServerSession(org.apache.qpid.transport.Connection connection,
org.apache.qpid.transport.SessionDelegate delegate,
org.apache.qpid.transport.Binary name,
long expiry)
ServerSession
public ServerSession(org.apache.qpid.transport.Connection connection,
org.apache.qpid.transport.SessionDelegate delegate,
org.apache.qpid.transport.Binary name,
long expiry,
ConnectionConfig connConfig)
setState
protected void setState(org.apache.qpid.transport.Session.State state)
- Overrides:
setState
in class org.apache.qpid.transport.Session
isFull
protected boolean isFull(int id)
- Overrides:
isFull
in class org.apache.qpid.transport.Session
enqueue
public void enqueue(ServerMessage message,
ArrayList<? extends BaseQueue> queues)
sendMessage
public void sendMessage(org.apache.qpid.transport.MessageTransfer xfr,
Runnable postIdSettingAction)
onMessageDispositionChange
public void onMessageDispositionChange(org.apache.qpid.transport.MessageTransfer xfr,
ServerSession.MessageDispositionChangeListener acceptListener)
accept
public void accept(org.apache.qpid.transport.RangeSet ranges)
release
public void release(org.apache.qpid.transport.RangeSet ranges)
reject
public void reject(org.apache.qpid.transport.RangeSet ranges)
acquire
public org.apache.qpid.transport.RangeSet acquire(org.apache.qpid.transport.RangeSet transfers)
dispositionChange
public void dispositionChange(org.apache.qpid.transport.RangeSet ranges,
org.apache.qpid.server.transport.ServerSession.MessageDispositionAction action)
removeDispositionListener
public void removeDispositionListener(org.apache.qpid.transport.Method method)
onClose
public void onClose()
awaitClose
protected void awaitClose()
- Overrides:
awaitClose
in class org.apache.qpid.transport.Session
acknowledge
public void acknowledge(Subscription_0_10 sub,
QueueEntry entry)
getSubscriptions
public Collection<Subscription_0_10> getSubscriptions()
register
public void register(String destination,
Subscription_0_10 sub)
getSubscription
public Subscription_0_10 getSubscription(String destination)
unregister
public void unregister(Subscription_0_10 sub)
isTransactional
public boolean isTransactional()
- Specified by:
isTransactional
in interface SessionConfig
selectTx
public void selectTx()
commit
public void commit()
rollback
public void rollback()
getTxnStarts
public Long getTxnStarts()
- Specified by:
getTxnStarts
in interface SessionConfig
getTxnCommits
public Long getTxnCommits()
- Specified by:
getTxnCommits
in interface SessionConfig
getTxnRejects
public Long getTxnRejects()
- Specified by:
getTxnRejects
in interface SessionConfig
getTxnCount
public Long getTxnCount()
- Specified by:
getTxnCount
in interface SessionConfig
getPrincipal
public Principal getPrincipal()
- Specified by:
getPrincipal
in interface PrincipalHolder
- Returns:
- a Principal that was used to authorized this session
addSessionCloseTask
public void addSessionCloseTask(ServerSession.Task task)
removeSessionCloseTask
public void removeSessionCloseTask(ServerSession.Task task)
getReference
public WeakReference<org.apache.qpid.transport.Session> getReference()
getMessageStore
public MessageStore getMessageStore()
getVirtualHost
public VirtualHost getVirtualHost()
- Specified by:
getVirtualHost
in interface SessionConfig
getId
public UUID getId()
- Specified by:
getId
in interface ConfiguredObject<SessionConfigType,SessionConfig>
getConfigType
public SessionConfigType getConfigType()
- Specified by:
getConfigType
in interface ConfiguredObject<SessionConfigType,SessionConfig>
getParent
public ConfiguredObject getParent()
- Specified by:
getParent
in interface ConfiguredObject<SessionConfigType,SessionConfig>
isDurable
public boolean isDurable()
- Specified by:
isDurable
in interface ConfiguredObject<SessionConfigType,SessionConfig>
isAttached
public boolean isAttached()
- Specified by:
isAttached
in interface SessionConfig
getDetachedLifespan
public long getDetachedLifespan()
- Specified by:
getDetachedLifespan
in interface SessionConfig
getExpiryTime
public Long getExpiryTime()
- Specified by:
getExpiryTime
in interface SessionConfig
getMaxClientRate
public Long getMaxClientRate()
- Specified by:
getMaxClientRate
in interface SessionConfig
getConnectionConfig
public ConnectionConfig getConnectionConfig()
- Specified by:
getConnectionConfig
in interface SessionConfig
getSessionName
public String getSessionName()
- Specified by:
getSessionName
in interface SessionConfig
getCreateTime
public long getCreateTime()
- Specified by:
getCreateTime
in interface ConfiguredObject<SessionConfigType,SessionConfig>
mgmtClose
public void mgmtClose()
- Specified by:
mgmtClose
in interface SessionConfig
getID
public Object getID()
- Specified by:
getID
in interface AMQSessionModel
getConnectionModel
public AMQConnectionModel getConnectionModel()
- Specified by:
getConnectionModel
in interface AMQSessionModel
getClientID
public String getClientID()
- Specified by:
getClientID
in interface AMQSessionModel
getLogSubject
public LogSubject getLogSubject()
- Specified by:
getLogSubject
in interface AMQSessionModel
toLogString
public String toLogString()
- Description copied from interface:
LogSubject
- Provides the log message as as String.
- Specified by:
toLogString
in interface LogSubject
Licensed to the Apache Software Foundation