Class TransactedTopicSession

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

com.swiftmq.impl.jms.standard.v750.TransactedTopicSession

All Implemented Interfaces:

com.swiftmq.jms.smqp.v750.SMQPVisitor, com.swiftmq.swiftlet.threadpool.EventProcessor, com.swiftmq.tools.requestreply.RequestService, com.swiftmq.tools.requestreply.RequestVisitor

public class TransactedTopicSession
extends TransactedSession

Field Summary

Fields inherited from class Session

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

Constructor Summary

Constructors

Constructor	Description
TransactedTopicSession(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 void	close()
String	toString()
void	visit(com.swiftmq.jms.smqp.v750.CloseConsumerRequest req)
void	visit(com.swiftmq.jms.smqp.v750.CloseProducerRequest req)
void	visit(com.swiftmq.jms.smqp.v750.CommitRequest req)
void	visit(com.swiftmq.jms.smqp.v750.CreateDurableRequest req)
void	visit(com.swiftmq.jms.smqp.v750.CreatePublisherRequest req)
void	visit(com.swiftmq.jms.smqp.v750.CreateSubscriberRequest req)
void	visit(com.swiftmq.jms.smqp.v750.DeleteDurableRequest req)

Methods inherited from class TransactedSession

isCountDeliveredRequests, purgeMarkedConsumers, purgeMarkedProducers, visit, visitGenericRequest

Methods inherited from class Session

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

Methods inherited from class Object

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

Constructor Details

TransactedTopicSession

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

Method Details

visit

public void visit(com.swiftmq.jms.smqp.v750.CommitRequest req)

Specified by:

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

Overrides:

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

visit

public void visit(com.swiftmq.jms.smqp.v750.CreatePublisherRequest req)

Specified by:

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

Overrides:

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

visit

public void visit(com.swiftmq.jms.smqp.v750.CloseProducerRequest req)

Specified by:

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

Overrides:

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

visit

public void visit(com.swiftmq.jms.smqp.v750.CreateSubscriberRequest req)

Specified by:

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

Overrides:

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

visit

public void visit(com.swiftmq.jms.smqp.v750.CloseConsumerRequest req)

Specified by:

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

Overrides:

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

visit

public void visit(com.swiftmq.jms.smqp.v750.CreateDurableRequest req)

Specified by:

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

Overrides:

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

visit

public void visit(com.swiftmq.jms.smqp.v750.DeleteDurableRequest req)

Specified by:

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

Overrides:

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

close

protected void close()

Overrides:

close in class Session

toString

public String toString()

Overrides:

toString in class TransactedSession