Package com.swiftmq.impl.jms.standard.v400

Class Session

java.lang.Object

com.swiftmq.jms.smqp.v400.SMQPVisitorAdapter

com.swiftmq.impl.jms.standard.v400.SessionVisitor

com.swiftmq.impl.jms.standard.v400.Session

All Implemented Interfaces:

SMQPVisitor, RequestService, RequestVisitor

Direct Known Subclasses:

NontransactedSession, TransactedSession

public abstract class Session
extends SessionVisitor
implements RequestService

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	closed
protected java.util.ArrayList	consumerList
protected SessionContext	ctx
protected int	dispatchId
protected java.util.ArrayList	producerList
protected int	recoveryEpoche
protected boolean	recoveryInProgress
protected ThreadPool	sessionTP

Constructor Summary

Constructors

Modifier	Constructor	Description
	Session(java.lang.String connectionTracePrefix, Entity sessionEntity, SingleProcessorQueue connectionOutboundQueue, int dispatchId, ActiveLogin activeLogin)
protected	Session(java.lang.String connectionTracePrefix, Entity sessionEntity, SingleProcessorQueue connectionOutboundQueue, int dispatchId, ActiveLogin activeLogin, int ackMode)

Method Summary

Modifier and Type	Method	Description
protected void	close()
protected boolean	isClosed()
void	serviceRequest(Request request)
java.lang.String	toString()
void	visitCloseSessionRequest(CloseSessionRequest request)
void	visitDeliveryItem(DeliveryItem item)
void	visitMessageDeliveredRequest(MessageDeliveredRequest req)
void	visitStartConsumerRequest(StartConsumerRequest req)

Methods inherited from class com.swiftmq.impl.jms.standard.v400.SessionVisitor

visitGenericRequest

Methods inherited from class com.swiftmq.jms.smqp.v400.SMQPVisitorAdapter

visitAcknowledgeMessageRequest, visitAssociateMessageRequest, visitAsyncMessageDeliveryRequest, visitAuthResponseRequest, visitCloseBrowserRequest, visitCloseConsumerRequest, visitCloseProducerRequest, visitCommitRequest, visitCreateBrowserRequest, visitCreateConsumerRequest, visitCreateDurableRequest, visitCreateProducerRequest, visitCreatePublisherRequest, visitCreateSessionRequest, visitCreateShadowConsumerRequest, visitCreateSubscriberRequest, visitCreateTmpQueueRequest, visitDeleteDurableRequest, visitDeleteTmpQueueRequest, visitDisconnectRequest, visitFetchBrowserMessageRequest, visitGetAuthChallengeRequest, visitGetClientIdRequest, visitGetMetaDataRequest, visitProduceMessageRequest, visitRecoverSessionRequest, visitRollbackRequest, visitRouterConnectRequest, visitSetClientIdRequest, visitXAResCommitRequest, visitXAResEndRequest, visitXAResPrepareRequest, visitXAResRecoverRequest, visitXAResRollbackRequest, visitXAResStartRequest

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

consumerList

protected java.util.ArrayList consumerList

producerList

protected java.util.ArrayList producerList

ctx

protected SessionContext ctx

dispatchId

protected int dispatchId

sessionTP

protected ThreadPool sessionTP

recoveryEpoche

protected int recoveryEpoche

recoveryInProgress

protected boolean recoveryInProgress

closed

protected boolean closed

Constructor Detail

Session

public Session(java.lang.String connectionTracePrefix,
               Entity sessionEntity,
               SingleProcessorQueue connectionOutboundQueue,
               int dispatchId,
               ActiveLogin activeLogin)

Session

protected Session(java.lang.String connectionTracePrefix,
                  Entity sessionEntity,
                  SingleProcessorQueue connectionOutboundQueue,
                  int dispatchId,
                  ActiveLogin activeLogin,
                  int ackMode)

Method Detail

visitStartConsumerRequest

public void visitStartConsumerRequest(StartConsumerRequest req)

Specified by:

visitStartConsumerRequest in interface SMQPVisitor

Overrides:

visitStartConsumerRequest in class SMQPVisitorAdapter

visitDeliveryItem

public void visitDeliveryItem(DeliveryItem item)

Overrides:

visitDeliveryItem in class SessionVisitor

visitMessageDeliveredRequest

public void visitMessageDeliveredRequest(MessageDeliveredRequest req)

Specified by:

visitMessageDeliveredRequest in interface SMQPVisitor

Overrides:

visitMessageDeliveredRequest in class SMQPVisitorAdapter

visitCloseSessionRequest

public void visitCloseSessionRequest(CloseSessionRequest request)

Specified by:

visitCloseSessionRequest in interface SMQPVisitor

Overrides:

visitCloseSessionRequest in class SMQPVisitorAdapter

serviceRequest

public void serviceRequest(Request request)

Specified by:

serviceRequest in interface RequestService

close

protected void close()

isClosed

protected boolean isClosed()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object