Package com.swiftmq.impl.jms.standard.v400

Class NontransactedSession

java.lang.Object

com.swiftmq.jms.smqp.v400.SMQPVisitorAdapter

com.swiftmq.impl.jms.standard.v400.SessionVisitor

com.swiftmq.impl.jms.standard.v400.Session

com.swiftmq.impl.jms.standard.v400.NontransactedSession

All Implemented Interfaces:

SMQPVisitor, RequestService, RequestVisitor

Direct Known Subclasses:

NontransactedQueueSession, NontransactedTopicSession, NontransactedUnifiedSession

public class NontransactedSession
extends Session

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.List	deliveredList

Fields inherited from class com.swiftmq.impl.jms.standard.v400.Session

closed, consumerList, ctx, dispatchId, producerList, recoveryEpoche, recoveryInProgress, sessionTP

Constructor Summary

Constructors

Constructor	Description
NontransactedSession(java.lang.String connectionTracePrefix, Entity sessionEntity, SingleProcessorQueue connectionOutboundQueue, int dispatchId, ActiveLogin activeLogin, int ackMode)

Method Summary

Modifier and Type	Method	Description
protected void	close()
java.lang.String	toString()
void	visitAcknowledgeMessageRequest(AcknowledgeMessageRequest req)
void	visitGenericRequest(GenericRequest request)
void	visitMessageDeliveredRequest(MessageDeliveredRequest req)
void	visitRecoverSessionRequest(RecoverSessionRequest req)

Methods inherited from class com.swiftmq.impl.jms.standard.v400.Session

isClosed, serviceRequest, visitCloseSessionRequest, visitDeliveryItem, visitStartConsumerRequest

Methods inherited from class com.swiftmq.jms.smqp.v400.SMQPVisitorAdapter

visitAssociateMessageRequest, visitAsyncMessageDeliveryRequest, visitAuthResponseRequest, visitCloseBrowserRequest, visitCloseConsumerRequest, visitCloseProducerRequest, visitCommitRequest, visitCreateBrowserRequest, visitCreateConsumerRequest, visitCreateDurableRequest, visitCreateProducerRequest, visitCreatePublisherRequest, visitCreateSessionRequest, visitCreateShadowConsumerRequest, visitCreateSubscriberRequest, visitCreateTmpQueueRequest, visitDeleteDurableRequest, visitDeleteTmpQueueRequest, visitDisconnectRequest, visitFetchBrowserMessageRequest, visitGetAuthChallengeRequest, visitGetClientIdRequest, visitGetMetaDataRequest, visitProduceMessageRequest, visitRollbackRequest, visitRouterConnectRequest, visitSetClientIdRequest, visitXAResCommitRequest, visitXAResEndRequest, visitXAResPrepareRequest, visitXAResRecoverRequest, visitXAResRollbackRequest, visitXAResStartRequest

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

deliveredList

protected java.util.List deliveredList

Constructor Detail

NontransactedSession

public NontransactedSession(java.lang.String connectionTracePrefix,
                            Entity sessionEntity,
                            SingleProcessorQueue connectionOutboundQueue,
                            int dispatchId,
                            ActiveLogin activeLogin,
                            int ackMode)

Method Detail

visitMessageDeliveredRequest

public void visitMessageDeliveredRequest(MessageDeliveredRequest req)

Specified by:

visitMessageDeliveredRequest in interface SMQPVisitor

Overrides:

visitMessageDeliveredRequest in class Session

visitAcknowledgeMessageRequest

public void visitAcknowledgeMessageRequest(AcknowledgeMessageRequest req)

Specified by:

visitAcknowledgeMessageRequest in interface SMQPVisitor

Overrides:

visitAcknowledgeMessageRequest in class SMQPVisitorAdapter

visitGenericRequest

public void visitGenericRequest(GenericRequest request)

Specified by:

visitGenericRequest in interface RequestVisitor

Overrides:

visitGenericRequest in class SessionVisitor

visitRecoverSessionRequest

public void visitRecoverSessionRequest(RecoverSessionRequest req)

Specified by:

visitRecoverSessionRequest in interface SMQPVisitor

Overrides:

visitRecoverSessionRequest in class SMQPVisitorAdapter

close

protected void close()

Overrides:

close in class Session

toString

public java.lang.String toString()

Overrides:

toString in class Session