Class NontransactedTopicSession
java.lang.Object
SMQPVisitorAdapter
com.swiftmq.impl.jms.standard.v750.SessionVisitor
com.swiftmq.impl.jms.standard.v750.Session
com.swiftmq.impl.jms.standard.v750.NontransactedSession
com.swiftmq.impl.jms.standard.v750.NontransactedTopicSession
-
Field Summary
Fields inherited from class com.swiftmq.impl.jms.standard.v750.NontransactedSession
deliveredListFields inherited from class com.swiftmq.impl.jms.standard.v750.Session
closed, consumerList, ctx, dispatchId, myConnection, producerList, recoveryEpoche, recoveryInProgress -
Constructor Summary
ConstructorsConstructorDescriptionNontransactedTopicSession(String connectionTracePrefix, Entity sessionEntity, EventLoop outboundLoop, int dispatchId, ActiveLogin activeLogin, int ackMode) -
Method Summary
Modifier and TypeMethodDescriptiontoString()voidvisit(CloseConsumerRequest req) voidvisit(CloseProducerRequest req) voidvisit(CreateDurableRequest req) voidvisit(CreatePublisherRequest req) voidvisit(CreateSubscriberRequest req) voidvisit(DeleteDurableRequest req) voidvisit(ProduceMessageRequest req) Methods inherited from class com.swiftmq.impl.jms.standard.v750.NontransactedSession
close, visitGenericRequestMethods inherited from class com.swiftmq.impl.jms.standard.v750.Session
getMyConnection, isClosed, isCountDeliveredRequests, process, serviceRequest, setMyConnection, setRecoveryEpoche, validateDestination
-
Constructor Details
-
NontransactedTopicSession
public NontransactedTopicSession(String connectionTracePrefix, Entity sessionEntity, EventLoop outboundLoop, int dispatchId, ActiveLogin activeLogin, int ackMode)
-
-
Method Details
-
visit
public void visit(ProduceMessageRequest req) - Overrides:
visitin classNontransactedSession
-
visit
public void visit(CreatePublisherRequest req) - Overrides:
visitin classNontransactedSession
-
visit
public void visit(CloseProducerRequest req) - Overrides:
visitin classNontransactedSession
-
visit
public void visit(CreateSubscriberRequest req) - Overrides:
visitin classNontransactedSession
-
visit
public void visit(CloseConsumerRequest req) - Overrides:
visitin classNontransactedSession
-
visit
public void visit(CreateDurableRequest req) - Overrides:
visitin classNontransactedSession
-
visit
public void visit(DeleteDurableRequest req) - Overrides:
visitin classNontransactedSession
-
toString
- Overrides:
toStringin classNontransactedSession
-