Package com.swiftmq.impl.jms.standard.v750

Class Session

java.lang.Object

SMQPVisitorAdapter

com.swiftmq.impl.jms.standard.v750.SessionVisitor

com.swiftmq.impl.jms.standard.v750.Session

Direct Known Subclasses:

NontransactedSession, TransactedSession

public abstract class Session
extends SessionVisitor

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	closed
protected <any>	consumerList
protected SessionContext	ctx
protected int	dispatchId
protected JMSConnection	myConnection
protected <any>	producerList
protected int	recoveryEpoche
protected boolean	recoveryInProgress

Constructor Summary

Constructors

Modifier	Constructor	Description
	Session(String connectionTracePrefix, Entity sessionEntity, EventLoop outboundLoop, int dispatchId, ActiveLogin activeLogin)
protected	Session(String connectionTracePrefix, Entity sessionEntity, EventLoop outboundLoop, int dispatchId, ActiveLogin activeLogin, int ackMode)

Method Summary

Modifier and Type	Method	Description
protected void	close()
JMSConnection	getMyConnection()
protected boolean	isClosed()
protected boolean	isCountDeliveredRequests()
void	process(List<Object> events)
void	serviceRequest(Request request)
void	setMyConnection(JMSConnection myConnection)
void	setRecoveryEpoche(int recoveryEpoche)
String	toString()
protected String	validateDestination(String queueName)
void	visit(CloseSessionRequest request)
void	visit(MessageDeliveredRequest req)
void	visit(StartConsumerRequest req)

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

visitGenericRequest

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

consumerList

protected <any> consumerList

producerList

protected <any> producerList

ctx

protected SessionContext ctx

dispatchId

protected int dispatchId

recoveryEpoche

protected int recoveryEpoche

recoveryInProgress

protected boolean recoveryInProgress

closed

protected volatile boolean closed

myConnection

protected JMSConnection myConnection

Constructor Details

Session

public Session(String connectionTracePrefix,
 Entity sessionEntity,
 EventLoop outboundLoop,
 int dispatchId,
 ActiveLogin activeLogin)

Session

protected Session(String connectionTracePrefix,
 Entity sessionEntity,
 EventLoop outboundLoop,
 int dispatchId,
 ActiveLogin activeLogin,
 int ackMode)

Method Details

getMyConnection

public JMSConnection getMyConnection()

setMyConnection

public void setMyConnection(JMSConnection myConnection)

validateDestination

protected String validateDestination(String queueName)
                              throws InvalidDestinationException

Throws:

InvalidDestinationException

setRecoveryEpoche

public void setRecoveryEpoche(int recoveryEpoche)

process

public void process(List<Object> events)

visit

public void visit(StartConsumerRequest req)

Overrides:

visit in class SessionVisitor

isCountDeliveredRequests

protected boolean isCountDeliveredRequests()

visit

public void visit(MessageDeliveredRequest req)

Overrides:

visit in class SessionVisitor

visit

public void visit(CloseSessionRequest request)

Overrides:

visit in class SessionVisitor

serviceRequest

public void serviceRequest(Request request)

close

protected void close()

isClosed

protected boolean isClosed()

toString

public String toString()