Class NontransactedUnifiedSession
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.NontransactedUnifiedSession
-
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
ConstructorDescriptionNontransactedUnifiedSession
(String connectionTracePrefix, Entity sessionEntity, EventLoop outboundLoop, int dispatchId, ActiveLogin activeLogin, int ackMode) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
close()
toString()
void
visit
(CloseBrowserRequest req) void
visit
(CloseConsumerRequest req) void
visit
(CloseProducerRequest 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) void
visit
(ProduceMessageRequest req) Methods inherited from class com.swiftmq.impl.jms.standard.v750.NontransactedSession
visitGenericRequest
Methods inherited from class com.swiftmq.impl.jms.standard.v750.Session
getMyConnection, isClosed, isCountDeliveredRequests, process, serviceRequest, setMyConnection, setRecoveryEpoche, validateDestination
-
Constructor Details
-
NontransactedUnifiedSession
public NontransactedUnifiedSession(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(CreateProducerRequest 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(CreateConsumerRequest 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
-
visit
public void visit(CreateBrowserRequest req) - Overrides:
visit
in classNontransactedSession
-
visit
public void visit(FetchBrowserMessageRequest req) - Overrides:
visit
in classNontransactedSession
-
visit
public void visit(CloseBrowserRequest req) - Overrides:
visit
in classNontransactedSession
-
close
protected void close()- Overrides:
close
in classNontransactedSession
-
toString
- Overrides:
toString
in classNontransactedSession
-