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

Class NontransactedTopicSession

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.NontransactedTopicSession

All Implemented Interfaces:

SMQPVisitor, RequestService, RequestVisitor

public class NontransactedTopicSession
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
NontransactedTopicSession(java.lang.String connectionTracePrefix, Entity sessionEntity, SingleProcessorQueue connectionOutboundQueue, int dispatchId, ActiveLogin activeLogin, int ackMode)

Method Summary

Modifier and Type	Method	Description
java.lang.String	toString()
void	visitCloseConsumerRequest(CloseConsumerRequest req)
void	visitCloseProducerRequest(CloseProducerRequest req)
void	visitCreateDurableRequest(CreateDurableRequest req)
void	visitCreatePublisherRequest(CreatePublisherRequest req)
void	visitCreateSubscriberRequest(CreateSubscriberRequest req)
void	visitDeleteDurableRequest(DeleteDurableRequest req)
void	visitProduceMessageRequest(ProduceMessageRequest req)

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

close, 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, visitCloseBrowserRequest, visitCommitRequest, visitCreateBrowserRequest, visitCreateConsumerRequest, visitCreateProducerRequest, visitCreateSessionRequest, visitCreateShadowConsumerRequest, visitCreateTmpQueueRequest, visitDeleteTmpQueueRequest, visitDisconnectRequest, visitFetchBrowserMessageRequest, 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

NontransactedTopicSession

public NontransactedTopicSession(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

visitCreatePublisherRequest

public void visitCreatePublisherRequest(CreatePublisherRequest req)

Specified by:

visitCreatePublisherRequest in interface SMQPVisitor

Overrides:

visitCreatePublisherRequest in class SMQPVisitorAdapter

visitCloseProducerRequest

public void visitCloseProducerRequest(CloseProducerRequest req)

Specified by:

visitCloseProducerRequest in interface SMQPVisitor

Overrides:

visitCloseProducerRequest in class SMQPVisitorAdapter

visitCreateSubscriberRequest

public void visitCreateSubscriberRequest(CreateSubscriberRequest req)

Specified by:

visitCreateSubscriberRequest in interface SMQPVisitor

Overrides:

visitCreateSubscriberRequest in class SMQPVisitorAdapter

visitCloseConsumerRequest

public void visitCloseConsumerRequest(CloseConsumerRequest req)

Specified by:

visitCloseConsumerRequest in interface SMQPVisitor

Overrides:

visitCloseConsumerRequest in class SMQPVisitorAdapter

visitCreateDurableRequest

public void visitCreateDurableRequest(CreateDurableRequest req)

Specified by:

visitCreateDurableRequest in interface SMQPVisitor

Overrides:

visitCreateDurableRequest in class SMQPVisitorAdapter

visitDeleteDurableRequest

public void visitDeleteDurableRequest(DeleteDurableRequest req)

Specified by:

visitDeleteDurableRequest in interface SMQPVisitor

Overrides:

visitDeleteDurableRequest in class SMQPVisitorAdapter

toString

public java.lang.String toString()

Overrides:

toString in class NontransactedSession