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
deliveredList
Fields inherited from class com.swiftmq.impl.jms.standard.v750.Session
closed, consumerList, ctx, dispatchId, myConnection, producerList, recoveryEpoche, recoveryInProgress
-
Constructor Summary
ConstructorDescriptionNontransactedTopicSession
(String connectionTracePrefix, Entity sessionEntity, EventLoop outboundLoop, int dispatchId, ActiveLogin activeLogin, int ackMode) -
Method Summary
Modifier and TypeMethodDescriptiontoString()
void
visit
(CloseConsumerRequest req) void
visit
(CloseProducerRequest req) void
visit
(CreateDurableRequest req) void
visit
(CreatePublisherRequest req) void
visit
(CreateSubscriberRequest req) void
visit
(DeleteDurableRequest req) void
visit
(ProduceMessageRequest req) Methods inherited from class com.swiftmq.impl.jms.standard.v750.NontransactedSession
close, visitGenericRequest
Methods 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:
visit
in classNontransactedSession
-
visit
public void visit(CreatePublisherRequest req) - Overrides:
visit
in classNontransactedSession
-
visit
public void visit(CloseProducerRequest req) - Overrides:
visit
in classNontransactedSession
-
visit
public void visit(CreateSubscriberRequest req) - Overrides:
visit
in classNontransactedSession
-
visit
public void visit(CloseConsumerRequest req) - Overrides:
visit
in classNontransactedSession
-
visit
public void visit(CreateDurableRequest req) - Overrides:
visit
in classNontransactedSession
-
visit
public void visit(DeleteDurableRequest req) - Overrides:
visit
in classNontransactedSession
-
toString
- Overrides:
toString
in classNontransactedSession
-