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
deliveredListFields inherited from class com.swiftmq.impl.jms.standard.v750.Session
closed, consumerList, ctx, dispatchId, myConnection, producerList, recoveryEpoche, recoveryInProgress -
Constructor Summary
ConstructorsConstructorDescriptionNontransactedQueueSession(String connectionTracePrefix, Entity sessionEntity, EventLoop outboundLoop, int dispatchId, ActiveLogin activeLogin, int ackMode) -
Method Summary
Modifier and TypeMethodDescriptionprotected voidclose()toString()voidvisit(CloseBrowserRequest req) voidvisit(CloseConsumerRequest req) voidvisit(CloseProducerRequest req) voidvisit(CreateBrowserRequest req) voidvisit(CreateConsumerRequest req) voidvisit(CreateProducerRequest req) voidvisit(FetchBrowserMessageRequest req) voidvisit(ProduceMessageRequest req) Methods inherited from class com.swiftmq.impl.jms.standard.v750.NontransactedSession
visitGenericRequestMethods 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:
visitin classNontransactedSession
-
visit
public void visit(CreateProducerRequest req) - Overrides:
visitin classNontransactedSession
-
visit
public void visit(CloseProducerRequest req) - Overrides:
visitin classNontransactedSession
-
visit
public void visit(CreateConsumerRequest req) - Overrides:
visitin classNontransactedSession
-
visit
public void visit(CloseConsumerRequest req) - Overrides:
visitin classNontransactedSession
-
visit
public void visit(CreateBrowserRequest req) - Overrides:
visitin classNontransactedSession
-
visit
public void visit(FetchBrowserMessageRequest req) - Overrides:
visitin classNontransactedSession
-
visit
public void visit(CloseBrowserRequest req) - Overrides:
visitin classNontransactedSession
-
close
protected void close()- Overrides:
closein classNontransactedSession
-
toString
- Overrides:
toStringin classNontransactedSession
-