org.apache.qpid.server.protocol.v1_0

Class Session_1_0

java.lang.Object

org.apache.qpid.server.protocol.v1_0.Session_1_0

All Implemented Interfaces:

Comparable<AMQSessionModel>, SessionEventListener, LogSubject, AMQSessionModel<Session_1_0>, Deletable<Session_1_0>

public class Session_1_0
extends Object
implements SessionEventListener, AMQSessionModel<Session_1_0>, LogSubject

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.qpid.amqp_1_0.transport.SessionEventListener

SessionEventListener.DefaultSessionEventListener

Field Summary

Fields inherited from interface org.apache.qpid.amqp_1_0.transport.SessionEventListener

DEFAULT

Constructor Summary

Constructors

Constructor and Description
Session_1_0(Connection_1_0 connection, SessionEndpoint endpoint)

Method Summary

Modifier and Type	Method and Description
void	addConsumerListener(ConsumerListener listener)
void	addDeleteTask(Action<? super Session_1_0> task)
void	addTicker(Ticker ticker)
void	block()
void	block(AMQQueue queue)
void	checkTransactionStatus(long openWarn, long openClose, long idleWarn, long idleClose) This method is called from the housekeeping thread to check the status of transactions on this session and react appropriately.
void	close()
void	close(AMQConstant cause, String message)
int	compareTo(AMQSessionModel o)
void	ensureConsumersNoticedStateChange()
AccessControlContext	getAccessControllerContext()
AMQPConnection<?>	getAMQPConnection()
boolean	getBlocking()
int	getChannelId()
String	getClientID()
Connection_1_0	getConnection()
Object	getConnectionReference()
int	getConsumerCount()
Collection<Consumer<?>>	getConsumers()
UUID	getId()
LogSubject	getLogSubject()
Session<?>	getModelObject()
Subject	getSubject()
ServerTransaction	getTransaction(Binary transactionId)
long	getTransactionStartTime() Return the time the current transaction started.
long	getTransactionUpdateTime() Return the time of the last activity on the current transaction.
Long	getTxnCommits()
Long	getTxnCount()
Long	getTxnRejects()
Long	getTxnStart()
int	getUnacknowledgedMessageCount()
void	notifyConsumerTargetCurrentStates()
protected void	performCloseTasks()
boolean	processPending()
void	remoteEnd(End end)
void	remoteLinkCreation(LinkEndpoint endpoint)
void	removeConsumerListener(ConsumerListener listener)
void	removeDeleteTask(Action<? super Session_1_0> task)
void	removeTicker(Ticker ticker)
void	setModelObject(Session<?> session)
String	toLogString() Provides the log message as as String.
String	toString()
void	transportStateChanged()
void	unblock()
void	unblock(AMQQueue queue)

Methods inherited from class java.lang.Object

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

Constructor Detail

Session_1_0

public Session_1_0(Connection_1_0 connection,
                   SessionEndpoint endpoint)

Method Detail

getAccessControllerContext

public AccessControlContext getAccessControllerContext()

remoteLinkCreation

public void remoteLinkCreation(LinkEndpoint endpoint)

Specified by:

remoteLinkCreation in interface SessionEventListener

getTransaction

public ServerTransaction getTransaction(Binary transactionId)

remoteEnd

public void remoteEnd(End end)

Specified by:

remoteEnd in interface SessionEventListener

getId

public UUID getId()

Specified by:

getId in interface AMQSessionModel<Session_1_0>

getAMQPConnection

public AMQPConnection<?> getAMQPConnection()

Specified by:

getAMQPConnection in interface AMQSessionModel<Session_1_0>

getClientID

public String getClientID()

Specified by:

getClientID in interface AMQSessionModel<Session_1_0>

close

public void close()

Specified by:

close in interface AMQSessionModel<Session_1_0>

performCloseTasks

protected void performCloseTasks()

close

public void close(AMQConstant cause,
                  String message)

Specified by:

close in interface AMQSessionModel<Session_1_0>

transportStateChanged

public void transportStateChanged()

Specified by:

transportStateChanged in interface AMQSessionModel<Session_1_0>

getLogSubject

public LogSubject getLogSubject()

Specified by:

getLogSubject in interface AMQSessionModel<Session_1_0>

checkTransactionStatus

public void checkTransactionStatus(long openWarn,
                                   long openClose,
                                   long idleWarn,
                                   long idleClose)

Description copied from interface: AMQSessionModel

This method is called from the housekeeping thread to check the status of transactions on this session and react appropriately. If a transaction is open for too long or idle for too long then a warning is logged or the connection is closed, depending on the configuration. An open transaction is one that has recent activity. The transaction age is counted from the time the transaction was started. An idle transaction is one that has had no activity, such as publishing or acknowledging messages.

Specified by:

checkTransactionStatus in interface AMQSessionModel<Session_1_0>

Parameters:

openWarn - time in milliseconds before alerting on open transaction

openClose - time in milliseconds before closing connection with open transaction

idleWarn - time in milliseconds before alerting on idle transaction

idleClose - time in milliseconds before closing connection with idle transaction

block

public void block(AMQQueue queue)

Specified by:

block in interface AMQSessionModel<Session_1_0>

unblock

public void unblock(AMQQueue queue)

Specified by:

unblock in interface AMQSessionModel<Session_1_0>

block

public void block()

Specified by:

block in interface AMQSessionModel<Session_1_0>

unblock

public void unblock()

Specified by:

unblock in interface AMQSessionModel<Session_1_0>

getBlocking

public boolean getBlocking()

Specified by:

getBlocking in interface AMQSessionModel<Session_1_0>

getConnectionReference

public Object getConnectionReference()

Specified by:

getConnectionReference in interface AMQSessionModel<Session_1_0>

getUnacknowledgedMessageCount

public int getUnacknowledgedMessageCount()

Specified by:

getUnacknowledgedMessageCount in interface AMQSessionModel<Session_1_0>

getTxnCount

public Long getTxnCount()

Specified by:

getTxnCount in interface AMQSessionModel<Session_1_0>

getTxnStart

public Long getTxnStart()

Specified by:

getTxnStart in interface AMQSessionModel<Session_1_0>

getTxnCommits

public Long getTxnCommits()

Specified by:

getTxnCommits in interface AMQSessionModel<Session_1_0>

getTxnRejects

public Long getTxnRejects()

Specified by:

getTxnRejects in interface AMQSessionModel<Session_1_0>

getChannelId

public int getChannelId()

Specified by:

getChannelId in interface AMQSessionModel<Session_1_0>

getConsumerCount

public int getConsumerCount()

Specified by:

getConsumerCount in interface AMQSessionModel<Session_1_0>

toLogString

public String toLogString()

Description copied from interface: LogSubject

Provides the log message as as String.

Specified by:

toLogString in interface LogSubject

Returns:

String the display representation of this LogSubject

compareTo

public int compareTo(AMQSessionModel o)

Specified by:

compareTo in interface Comparable<AMQSessionModel>

getConnection

public Connection_1_0 getConnection()

addDeleteTask

public void addDeleteTask(Action<? super Session_1_0> task)

Specified by:

addDeleteTask in interface Deletable<Session_1_0>

removeDeleteTask

public void removeDeleteTask(Action<? super Session_1_0> task)

Specified by:

removeDeleteTask in interface Deletable<Session_1_0>

getSubject

public Subject getSubject()

getConsumers

public Collection<Consumer<?>> getConsumers()

Specified by:

getConsumers in interface AMQSessionModel<Session_1_0>

addConsumerListener

public void addConsumerListener(ConsumerListener listener)

Specified by:

addConsumerListener in interface AMQSessionModel<Session_1_0>

removeConsumerListener

public void removeConsumerListener(ConsumerListener listener)

Specified by:

removeConsumerListener in interface AMQSessionModel<Session_1_0>

setModelObject

public void setModelObject(Session<?> session)

Specified by:

setModelObject in interface AMQSessionModel<Session_1_0>

getModelObject

public Session<?> getModelObject()

Specified by:

getModelObject in interface AMQSessionModel<Session_1_0>

getTransactionStartTime

public long getTransactionStartTime()

Description copied from interface: AMQSessionModel

Return the time the current transaction started.

Specified by:

getTransactionStartTime in interface AMQSessionModel<Session_1_0>

Returns:

the time this transaction started or 0 if not in a transaction

getTransactionUpdateTime

public long getTransactionUpdateTime()

Description copied from interface: AMQSessionModel

Return the time of the last activity on the current transaction.

Specified by:

getTransactionUpdateTime in interface AMQSessionModel<Session_1_0>

Returns:

the time of the last activity or 0 if not in a transaction

processPending

public boolean processPending()

Specified by:

processPending in interface AMQSessionModel<Session_1_0>

addTicker

public void addTicker(Ticker ticker)

Specified by:

addTicker in interface AMQSessionModel<Session_1_0>

removeTicker

public void removeTicker(Ticker ticker)

Specified by:

removeTicker in interface AMQSessionModel<Session_1_0>

notifyConsumerTargetCurrentStates

public void notifyConsumerTargetCurrentStates()

Specified by:

notifyConsumerTargetCurrentStates in interface AMQSessionModel<Session_1_0>

ensureConsumersNoticedStateChange

public void ensureConsumersNoticedStateChange()

Specified by:

ensureConsumersNoticedStateChange in interface AMQSessionModel<Session_1_0>

toString

public String toString()

Overrides:

toString in class Object