Package com.swiftmq.impl.jms.standard.v630

Class NontransactedTopicSession

java.lang.Object

com.swiftmq.jms.smqp.v630.SMQPVisitorAdapter

com.swiftmq.impl.jms.standard.v630.SessionVisitor

com.swiftmq.impl.jms.standard.v630.Session

com.swiftmq.impl.jms.standard.v630.NontransactedSession

com.swiftmq.impl.jms.standard.v630.NontransactedTopicSession

All Implemented Interfaces:

SMQPVisitor, RequestService, RequestVisitor

public class NontransactedTopicSession
extends NontransactedSession

Field Summary

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

deliveredList

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

closed, consumerList, ctx, dispatchId, myConnection, 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	visit(CloseConsumerRequest req)
void	visit(CloseProducerRequest req)
void	visit(CreateDurableRequest req)
void	visit(CreatePublisherRequest req)
void	visit(CreateSubscriberRequest req)
void	visit(DeleteDurableRequest req)
void	visit(ProduceMessageRequest req)

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

close, visit, visit, visit, visitGenericRequest

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

getMyConnection, isClosed, serviceRequest, setMyConnection, setRecoveryEpoche, validateDestination, visit, visit, visit, visit, visit

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

visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit

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

visit

public void visit(ProduceMessageRequest req)

Specified by:

visit in interface SMQPVisitor

Overrides:

visit in class SMQPVisitorAdapter

visit

public void visit(CreatePublisherRequest req)

Specified by:

visit in interface SMQPVisitor

Overrides:

visit in class SMQPVisitorAdapter

visit

public void visit(CloseProducerRequest req)

Specified by:

visit in interface SMQPVisitor

Overrides:

visit in class SMQPVisitorAdapter

visit

public void visit(CreateSubscriberRequest req)

Specified by:

visit in interface SMQPVisitor

Overrides:

visit in class SMQPVisitorAdapter

visit

public void visit(CloseConsumerRequest req)

Specified by:

visit in interface SMQPVisitor

Overrides:

visit in class SMQPVisitorAdapter

visit

public void visit(CreateDurableRequest req)

Specified by:

visit in interface SMQPVisitor

Overrides:

visit in class SMQPVisitorAdapter

visit

public void visit(DeleteDurableRequest req)

Specified by:

visit in interface SMQPVisitor

Overrides:

visit in class SMQPVisitorAdapter

toString

public java.lang.String toString()

Overrides:

toString in class NontransactedSession