Package com.swiftmq.impl.jms.standard.v630

Class TransactedSession

java.lang.Object

com.swiftmq.jms.smqp.v630.SMQPVisitorAdapter

com.swiftmq.impl.jms.standard.v630.SessionVisitor

com.swiftmq.impl.jms.standard.v630.Session

com.swiftmq.impl.jms.standard.v630.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.v630.Session

closed, consumerList, ctx, dispatchId, myConnection, 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	visit(RollbackRequest req)
void	visitGenericRequest(GenericRequest request)

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

close, getMyConnection, isClosed, serviceRequest, setMyConnection, setRecoveryEpoche, validateDestination, visit, visit, visit, visit, visit, visit

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

visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit

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

visit

public void visit(RollbackRequest req)

Specified by:

visit in interface SMQPVisitor

Overrides:

visit in class SMQPVisitorAdapter

toString

public java.lang.String toString()

Overrides:

toString in class Session