Class NontransactedQueueSession
- 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.NontransactedQueueSession
-
- All Implemented Interfaces:
SMQPVisitor
,RequestService
,RequestVisitor
public class NontransactedQueueSession 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 NontransactedQueueSession(java.lang.String connectionTracePrefix, Entity sessionEntity, SingleProcessorQueue connectionOutboundQueue, int dispatchId, ActiveLogin activeLogin, int ackMode)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
close()
java.lang.String
toString()
void
visit(CloseBrowserRequest req)
void
visit(CloseConsumerRequest req)
void
visit(CloseProducerRequest req)
void
visit(CreateBrowserRequest req)
void
visit(CreateConsumerRequest req)
void
visit(CreateProducerRequest req)
void
visit(FetchBrowserMessageRequest req)
void
visit(ProduceMessageRequest req)
-
Methods inherited from class com.swiftmq.impl.jms.standard.v630.NontransactedSession
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
-
-
-
-
Constructor Detail
-
NontransactedQueueSession
public NontransactedQueueSession(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 interfaceSMQPVisitor
- Overrides:
visit
in classSMQPVisitorAdapter
-
visit
public void visit(CreateProducerRequest req)
- Specified by:
visit
in interfaceSMQPVisitor
- Overrides:
visit
in classSMQPVisitorAdapter
-
visit
public void visit(CloseProducerRequest req)
- Specified by:
visit
in interfaceSMQPVisitor
- Overrides:
visit
in classSMQPVisitorAdapter
-
visit
public void visit(CreateConsumerRequest req)
- Specified by:
visit
in interfaceSMQPVisitor
- Overrides:
visit
in classSMQPVisitorAdapter
-
visit
public void visit(CloseConsumerRequest req)
- Specified by:
visit
in interfaceSMQPVisitor
- Overrides:
visit
in classSMQPVisitorAdapter
-
visit
public void visit(CreateBrowserRequest req)
- Specified by:
visit
in interfaceSMQPVisitor
- Overrides:
visit
in classSMQPVisitorAdapter
-
visit
public void visit(FetchBrowserMessageRequest req)
- Specified by:
visit
in interfaceSMQPVisitor
- Overrides:
visit
in classSMQPVisitorAdapter
-
visit
public void visit(CloseBrowserRequest req)
- Specified by:
visit
in interfaceSMQPVisitor
- Overrides:
visit
in classSMQPVisitorAdapter
-
close
protected void close()
- Overrides:
close
in classNontransactedSession
-
toString
public java.lang.String toString()
- Overrides:
toString
in classNontransactedSession
-
-