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

Class TransactedUnifiedSession

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

com.swiftmq.impl.jms.standard.v750.TransactedUnifiedSession

public class TransactedUnifiedSession
extends TransactedSession

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
TransactedUnifiedSession(String connectionTracePrefix, Entity sessionEntity, EventLoop outboundLoop, int dispatchId, ActiveLogin activeLogin)

Method Summary

Modifier and Type	Method	Description
protected void	close()
String	toString()
void	visit(CloseBrowserRequest req)
void	visit(CloseConsumerRequest req)
void	visit(CloseProducerRequest req)
void	visit(CommitRequest req)
void	visit(CreateBrowserRequest req)
void	visit(CreateConsumerRequest req)
void	visit(CreateDurableRequest req)
void	visit(CreateProducerRequest req)
void	visit(CreatePublisherRequest req)
void	visit(CreateSubscriberRequest req)
void	visit(DeleteDurableRequest req)
void	visit(FetchBrowserMessageRequest req)

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

isCountDeliveredRequests, purgeMarkedConsumers, purgeMarkedProducers, visitGenericRequest

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

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

TransactedUnifiedSession

public TransactedUnifiedSession(String connectionTracePrefix,
 Entity sessionEntity,
 EventLoop outboundLoop,
 int dispatchId,
 ActiveLogin activeLogin)

Method Details

visit

public void visit(CommitRequest req)

Overrides:

visit in class TransactedSession

visit

public void visit(CreateProducerRequest req)

Overrides:

visit in class TransactedSession

visit

public void visit(CreatePublisherRequest req)

Overrides:

visit in class TransactedSession

visit

public void visit(CloseProducerRequest req)

Overrides:

visit in class TransactedSession

visit

public void visit(CreateConsumerRequest req)

Overrides:

visit in class TransactedSession

visit

public void visit(CreateSubscriberRequest req)

Overrides:

visit in class TransactedSession

visit

public void visit(CloseConsumerRequest req)

Overrides:

visit in class TransactedSession

visit

public void visit(CreateDurableRequest req)

Overrides:

visit in class TransactedSession

visit

public void visit(DeleteDurableRequest req)

Overrides:

visit in class TransactedSession

visit

public void visit(CreateBrowserRequest req)

Overrides:

visit in class TransactedSession

visit

public void visit(FetchBrowserMessageRequest req)

Overrides:

visit in class TransactedSession

visit

public void visit(CloseBrowserRequest req)

Overrides:

visit in class TransactedSession

close

protected void close()

Overrides:

close in class Session

toString

public String toString()

Overrides:

toString in class TransactedSession