org.apache.qpid.server.transport
Class ServerSession

java.lang.Object
  extended by org.apache.qpid.transport.SessionInvoker
      extended by org.apache.qpid.transport.Session
          extended by 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 Class Summary
static interface ServerSession.MessageDispositionChangeListener
           
static interface ServerSession.Task
           
 
Nested classes/interfaces inherited from class org.apache.qpid.transport.Session
org.apache.qpid.transport.Session.State
 
Field Summary
 
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)
           
 
Method Summary
 void accept(org.apache.qpid.transport.RangeSet ranges)
           
 void acknowledge(Subscription_0_10 sub, QueueEntry entry)
           
 org.apache.qpid.transport.RangeSet acquire(org.apache.qpid.transport.RangeSet transfers)
           
 void addSessionCloseTask(ServerSession.Task task)
           
protected  void awaitClose()
           
 void commit()
           
 void dispositionChange(org.apache.qpid.transport.RangeSet ranges, org.apache.qpid.server.transport.ServerSession.MessageDispositionAction action)
           
 void enqueue(ServerMessage message, ArrayList<? extends BaseQueue> queues)
           
 String getClientID()
           
 SessionConfigType getConfigType()
           
 ConnectionConfig getConnectionConfig()
           
 AMQConnectionModel getConnectionModel()
           
 long getCreateTime()
           
 long getDetachedLifespan()
           
 Long getExpiryTime()
           
 UUID getId()
           
 Object getID()
           
 LogSubject getLogSubject()
           
 Long getMaxClientRate()
           
 MessageStore getMessageStore()
           
 ConfiguredObject getParent()
           
 Principal getPrincipal()
           
 WeakReference<org.apache.qpid.transport.Session> getReference()
           
 String getSessionName()
           
 Subscription_0_10 getSubscription(String destination)
           
 Collection<Subscription_0_10> getSubscriptions()
           
 Long getTxnCommits()
           
 Long getTxnCount()
           
 Long getTxnRejects()
           
 Long getTxnStarts()
           
 VirtualHost getVirtualHost()
           
 boolean isAttached()
           
 boolean isDurable()
           
protected  boolean isFull(int id)
           
 boolean isTransactional()
           
 void mgmtClose()
           
 void onClose()
           
 void onMessageDispositionChange(org.apache.qpid.transport.MessageTransfer xfr, ServerSession.MessageDispositionChangeListener acceptListener)
           
 void register(String destination, Subscription_0_10 sub)
           
 void reject(org.apache.qpid.transport.RangeSet ranges)
           
 void release(org.apache.qpid.transport.RangeSet ranges)
           
 void removeDispositionListener(org.apache.qpid.transport.Method method)
           
 void removeSessionCloseTask(ServerSession.Task task)
           
 void rollback()
           
 void selectTx()
           
 void sendMessage(org.apache.qpid.transport.MessageTransfer xfr, Runnable postIdSettingAction)
           
protected  void setState(org.apache.qpid.transport.Session.State state)
           
 String toLogString()
          Provides the log message as as String.
 void unregister(Subscription_0_10 sub)
           
 
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
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.qpid.server.configuration.SessionConfig
getChannel
 

Constructor Detail

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)
Method Detail

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