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:

com.swiftmq.jms.smqp.v630.SMQPVisitor, com.swiftmq.tools.requestreply.RequestService, com.swiftmq.tools.requestreply.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(String connectionTracePrefix, com.swiftmq.mgmt.Entity sessionEntity, com.swiftmq.tools.queue.SingleProcessorQueue connectionOutboundQueue, int dispatchId, com.swiftmq.swiftlet.auth.ActiveLogin activeLogin)

Method Summary

Modifier and Type	Method	Description
protected void	purgeMarkedConsumers()
protected void	purgeMarkedProducers()
String	toString()
void	visit(com.swiftmq.jms.smqp.v630.RollbackRequest req)
void	visitGenericRequest(com.swiftmq.tools.requestreply.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 Details

TransactedSession

public TransactedSession(String connectionTracePrefix,
 com.swiftmq.mgmt.Entity sessionEntity,
 com.swiftmq.tools.queue.SingleProcessorQueue connectionOutboundQueue,
 int dispatchId,
 com.swiftmq.swiftlet.auth.ActiveLogin activeLogin)

Method Details

purgeMarkedProducers

protected void purgeMarkedProducers()
                             throws Exception

Throws:

Exception

purgeMarkedConsumers

protected void purgeMarkedConsumers()
                             throws Exception

Throws:

Exception

visitGenericRequest

public void visitGenericRequest(com.swiftmq.tools.requestreply.GenericRequest request)

Specified by:

visitGenericRequest in interface com.swiftmq.tools.requestreply.RequestVisitor

Overrides:

visitGenericRequest in class SessionVisitor

visit

public void visit(com.swiftmq.jms.smqp.v630.RollbackRequest req)

Specified by:

visit in interface com.swiftmq.jms.smqp.v630.SMQPVisitor

Overrides:

visit in class com.swiftmq.jms.smqp.v630.SMQPVisitorAdapter

toString

public String toString()

Overrides:

toString in class Session