Package com.swiftmq.impl.jms.standard.v750

Class TransactedSession

java.lang.Object

SMQPVisitorAdapter

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

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

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

Direct Known Subclasses:

TransactedQueueSession, TransactedTopicSession, TransactedUnifiedSession

public abstract class TransactedSession
extends Session

Field Summary

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

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

Constructor Summary

Constructors

Constructor	Description
TransactedSession(String connectionTracePrefix, Entity sessionEntity, EventLoop outboundLoop, int dispatchId, ActiveLogin activeLogin)

Method Summary

Modifier and Type	Method	Description
protected boolean	isCountDeliveredRequests()
protected void	purgeMarkedConsumers()
protected void	purgeMarkedProducers()
String	toString()
void	visit(RollbackRequest req)
void	visitGenericRequest(GenericRequest request)

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

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

Methods inherited from class java.lang.Object

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

Constructor Details

TransactedSession

public TransactedSession(String connectionTracePrefix,
 Entity sessionEntity,
 EventLoop outboundLoop,
 int dispatchId,
 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(GenericRequest request)

Overrides:

visitGenericRequest in class SessionVisitor

visit

public void visit(RollbackRequest req)

Overrides:

visit in class Session

toString

public String toString()

Overrides:

toString in class Session