Class TransactedSession

java.lang.Object

com.swiftmq.jms.smqp.v750.SMQPVisitorAdapter

com.swiftmq.impl.jms.standard.v750.SessionVisitor

com.swiftmq.impl.jms.standard.v750.Session

com.swiftmq.impl.jms.standard.v750.TransactedSession

All Implemented Interfaces:

com.swiftmq.jms.smqp.v750.SMQPVisitor, com.swiftmq.swiftlet.threadpool.EventProcessor, 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 Session

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

Constructor Summary

Constructors

Constructor	Description
TransactedSession(String connectionTracePrefix, com.swiftmq.mgmt.Entity sessionEntity, com.swiftmq.swiftlet.threadpool.EventLoop outboundLoop, int dispatchId, com.swiftmq.swiftlet.auth.ActiveLogin activeLogin)

Method Summary

Modifier and Type	Method	Description
protected boolean	isCountDeliveredRequests()
protected void	purgeMarkedConsumers()
protected void	purgeMarkedProducers()
String	toString()
void	visit(com.swiftmq.jms.smqp.v750.RollbackRequest req)
void	visitGenericRequest(com.swiftmq.tools.requestreply.GenericRequest request)

Methods inherited from class Session

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

Methods inherited from class com.swiftmq.jms.smqp.v750.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 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.swiftlet.threadpool.EventLoop outboundLoop,
 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

isCountDeliveredRequests

protected boolean isCountDeliveredRequests()

Overrides:

isCountDeliveredRequests in class Session

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.v750.RollbackRequest req)

Specified by:

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

Overrides:

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

toString

public String toString()

Overrides:

toString in class Session