Class NontransactedQueueSession
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.NontransactedQueueSession
-
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
ConstructorDescriptionNontransactedQueueSession
(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
(CreateProducerRequest 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
-
NontransactedQueueSession
public NontransactedQueueSession(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(CloseProducerRequest req) - Overrides:
visit
in classNontransactedSession
-
visit
public void visit(CreateConsumerRequest req) - Overrides:
visit
in classNontransactedSession
-
visit
public void visit(CloseConsumerRequest 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
-