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
deliveredListFields inherited from class com.swiftmq.impl.jms.standard.v750.Session
closed, consumerList, ctx, dispatchId, myConnection, producerList, recoveryEpoche, recoveryInProgress -
Constructor Summary
ConstructorsConstructorDescriptionNontransactedUnifiedSession(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(CreateDurableRequest req) voidvisit(CreateProducerRequest req) voidvisit(CreatePublisherRequest req) voidvisit(CreateSubscriberRequest req) voidvisit(DeleteDurableRequest 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
-
NontransactedUnifiedSession
public NontransactedUnifiedSession(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(CreatePublisherRequest 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(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
-
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
-