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

Class NontransactedQueueSession

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

com.swiftmq.impl.jms.standard.v400.NontransactedQueueSession

All Implemented Interfaces:

SMQPVisitor, RequestService, RequestVisitor

public class NontransactedQueueSession
extends NontransactedSession

Field Summary

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

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
NontransactedQueueSession(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	visitCloseBrowserRequest(CloseBrowserRequest req)
void	visitCloseConsumerRequest(CloseConsumerRequest req)
void	visitCloseProducerRequest(CloseProducerRequest req)
void	visitCreateBrowserRequest(CreateBrowserRequest req)
void	visitCreateConsumerRequest(CreateConsumerRequest req)
void	visitCreateProducerRequest(CreateProducerRequest req)
void	visitFetchBrowserMessageRequest(FetchBrowserMessageRequest req)
void	visitProduceMessageRequest(ProduceMessageRequest req)

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

visitAcknowledgeMessageRequest, visitGenericRequest, visitMessageDeliveredRequest, visitRecoverSessionRequest

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, visitCommitRequest, visitCreateDurableRequest, visitCreatePublisherRequest, visitCreateSessionRequest, visitCreateShadowConsumerRequest, visitCreateSubscriberRequest, visitCreateTmpQueueRequest, visitDeleteDurableRequest, visitDeleteTmpQueueRequest, visitDisconnectRequest, visitGetAuthChallengeRequest, visitGetClientIdRequest, visitGetMetaDataRequest, 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

Constructor Detail

NontransactedQueueSession

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

Method Detail

visitProduceMessageRequest

public void visitProduceMessageRequest(ProduceMessageRequest req)

Specified by:

visitProduceMessageRequest in interface SMQPVisitor

Overrides:

visitProduceMessageRequest in class SMQPVisitorAdapter

visitCreateProducerRequest

public void visitCreateProducerRequest(CreateProducerRequest req)

Specified by:

visitCreateProducerRequest in interface SMQPVisitor

Overrides:

visitCreateProducerRequest in class SMQPVisitorAdapter

visitCloseProducerRequest

public void visitCloseProducerRequest(CloseProducerRequest req)

Specified by:

visitCloseProducerRequest in interface SMQPVisitor

Overrides:

visitCloseProducerRequest in class SMQPVisitorAdapter

visitCreateConsumerRequest

public void visitCreateConsumerRequest(CreateConsumerRequest req)

Specified by:

visitCreateConsumerRequest in interface SMQPVisitor

Overrides:

visitCreateConsumerRequest in class SMQPVisitorAdapter

visitCloseConsumerRequest

public void visitCloseConsumerRequest(CloseConsumerRequest req)

Specified by:

visitCloseConsumerRequest in interface SMQPVisitor

Overrides:

visitCloseConsumerRequest in class SMQPVisitorAdapter

visitCreateBrowserRequest

public void visitCreateBrowserRequest(CreateBrowserRequest req)

Specified by:

visitCreateBrowserRequest in interface SMQPVisitor

Overrides:

visitCreateBrowserRequest in class SMQPVisitorAdapter

visitFetchBrowserMessageRequest

public void visitFetchBrowserMessageRequest(FetchBrowserMessageRequest req)

Specified by:

visitFetchBrowserMessageRequest in interface SMQPVisitor

Overrides:

visitFetchBrowserMessageRequest in class SMQPVisitorAdapter

visitCloseBrowserRequest

public void visitCloseBrowserRequest(CloseBrowserRequest req)

Specified by:

visitCloseBrowserRequest in interface SMQPVisitor

Overrides:

visitCloseBrowserRequest in class SMQPVisitorAdapter

close

protected void close()

Overrides:

close in class NontransactedSession

toString

public java.lang.String toString()

Overrides:

toString in class NontransactedSession