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

Class TransactedSession

java.lang.Object

com.swiftmq.jms.smqp.v400.SMQPVisitorAdapter

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

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

com.swiftmq.impl.jms.standard.v400.TransactedSession

All Implemented Interfaces:

SMQPVisitor, RequestService, RequestVisitor

Direct Known Subclasses:

TransactedQueueSession, TransactedTopicSession, TransactedUnifiedSession

public abstract class TransactedSession
extends Session

Field Summary

Fields inherited from class com.swiftmq.impl.jms.standard.v400.Session

closed, consumerList, ctx, dispatchId, producerList, recoveryEpoche, recoveryInProgress, sessionTP

Constructor Summary

Constructors

Constructor	Description
TransactedSession(java.lang.String connectionTracePrefix, Entity sessionEntity, SingleProcessorQueue connectionOutboundQueue, int dispatchId, ActiveLogin activeLogin)

Method Summary

Modifier and Type	Method	Description
protected void	purgeMarkedConsumers()
protected void	purgeMarkedProducers()
java.lang.String	toString()
void	visitGenericRequest(GenericRequest request)
void	visitRollbackRequest(RollbackRequest req)

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

close, isClosed, serviceRequest, visitCloseSessionRequest, visitDeliveryItem, visitMessageDeliveredRequest, visitStartConsumerRequest

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, 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

Constructor Detail

TransactedSession

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

Method Detail

purgeMarkedProducers

protected void purgeMarkedProducers()
                             throws java.lang.Exception

Throws:

java.lang.Exception

purgeMarkedConsumers

protected void purgeMarkedConsumers()
                             throws java.lang.Exception

Throws:

java.lang.Exception

visitGenericRequest

public void visitGenericRequest(GenericRequest request)

Specified by:

visitGenericRequest in interface RequestVisitor

Overrides:

visitGenericRequest in class SessionVisitor

visitRollbackRequest

public void visitRollbackRequest(RollbackRequest req)

Specified by:

visitRollbackRequest in interface SMQPVisitor

Overrides:

visitRollbackRequest in class SMQPVisitorAdapter

toString

public java.lang.String toString()

Overrides:

toString in class Session