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

Class Session

java.lang.Object

com.swiftmq.jms.smqp.v630.SMQPVisitorAdapter

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

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

All Implemented Interfaces:

com.swiftmq.jms.smqp.v630.SMQPVisitor, com.swiftmq.tools.requestreply.RequestService, com.swiftmq.tools.requestreply.RequestVisitor

Direct Known Subclasses:

NontransactedSession, TransactedSession

public abstract class Session
extends SessionVisitor
implements com.swiftmq.tools.requestreply.RequestService

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	closed
protected ArrayList	consumerList
protected SessionContext	ctx
protected int	dispatchId
protected JMSConnection	myConnection
protected ArrayList	producerList
protected int	recoveryEpoche
protected boolean	recoveryInProgress
protected com.swiftmq.swiftlet.threadpool.ThreadPool	sessionTP

Constructor Summary

Constructors

Modifier	Constructor	Description
	Session(String connectionTracePrefix, com.swiftmq.mgmt.Entity sessionEntity, com.swiftmq.tools.queue.SingleProcessorQueue connectionOutboundQueue, int dispatchId, com.swiftmq.swiftlet.auth.ActiveLogin activeLogin)
protected	Session(String connectionTracePrefix, com.swiftmq.mgmt.Entity sessionEntity, com.swiftmq.tools.queue.SingleProcessorQueue connectionOutboundQueue, int dispatchId, com.swiftmq.swiftlet.auth.ActiveLogin activeLogin, int ackMode)

Method Summary

Modifier and Type	Method	Description
protected void	close()
JMSConnection	getMyConnection()
protected boolean	isClosed()
void	serviceRequest(com.swiftmq.tools.requestreply.Request request)
void	setMyConnection(JMSConnection myConnection)
void	setRecoveryEpoche(int recoveryEpoche)
String	toString()
protected String	validateDestination(String queueName)
void	visit(DeliveryItem item)
void	visit(RegisterMessageProcessor request)
void	visit(RunMessageProcessor request)
void	visit(com.swiftmq.jms.smqp.v630.CloseSessionRequest request)
void	visit(com.swiftmq.jms.smqp.v630.MessageDeliveredRequest req)
void	visit(com.swiftmq.jms.smqp.v630.StartConsumerRequest req)

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

visitGenericRequest

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, 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

Field Details

consumerList

protected ArrayList consumerList

producerList

protected ArrayList producerList

ctx

protected SessionContext ctx

dispatchId

protected int dispatchId

sessionTP

protected com.swiftmq.swiftlet.threadpool.ThreadPool sessionTP

recoveryEpoche

protected int recoveryEpoche

recoveryInProgress

protected boolean recoveryInProgress

closed

protected boolean closed

myConnection

protected JMSConnection myConnection

Constructor Details

Session

public Session(String connectionTracePrefix,
 com.swiftmq.mgmt.Entity sessionEntity,
 com.swiftmq.tools.queue.SingleProcessorQueue connectionOutboundQueue,
 int dispatchId,
 com.swiftmq.swiftlet.auth.ActiveLogin activeLogin)

Session

protected Session(String connectionTracePrefix,
 com.swiftmq.mgmt.Entity sessionEntity,
 com.swiftmq.tools.queue.SingleProcessorQueue connectionOutboundQueue,
 int dispatchId,
 com.swiftmq.swiftlet.auth.ActiveLogin activeLogin,
 int ackMode)

Method Details

getMyConnection

public JMSConnection getMyConnection()

setMyConnection

public void setMyConnection(JMSConnection myConnection)

validateDestination

protected String validateDestination(String queueName)
                              throws javax.jms.InvalidDestinationException

Throws:

javax.jms.InvalidDestinationException

setRecoveryEpoche

public void setRecoveryEpoche(int recoveryEpoche)

visit

public void visit(com.swiftmq.jms.smqp.v630.StartConsumerRequest req)

Specified by:

visit in interface com.swiftmq.jms.smqp.v630.SMQPVisitor

Overrides:

visit in class com.swiftmq.jms.smqp.v630.SMQPVisitorAdapter

visit

public void visit(DeliveryItem item)

Overrides:

visit in class SessionVisitor

visit

public void visit(RegisterMessageProcessor request)

Overrides:

visit in class SessionVisitor

visit

public void visit(RunMessageProcessor request)

Overrides:

visit in class SessionVisitor

visit

public void visit(com.swiftmq.jms.smqp.v630.MessageDeliveredRequest req)

Specified by:

visit in interface com.swiftmq.jms.smqp.v630.SMQPVisitor

Overrides:

visit in class com.swiftmq.jms.smqp.v630.SMQPVisitorAdapter

visit

public void visit(com.swiftmq.jms.smqp.v630.CloseSessionRequest request)

Specified by:

visit in interface com.swiftmq.jms.smqp.v630.SMQPVisitor

Overrides:

visit in class com.swiftmq.jms.smqp.v630.SMQPVisitorAdapter

serviceRequest

public void serviceRequest(com.swiftmq.tools.requestreply.Request request)

Specified by:

serviceRequest in interface com.swiftmq.tools.requestreply.RequestService

close

protected void close()

isClosed

protected boolean isClosed()

toString

public String toString()

Overrides:

toString in class Object