public class Session_1_0 extends Object implements SessionEventListener, AMQSessionModel<Session_1_0>, LogSubject
SessionEventListener.DefaultSessionEventListener
DEFAULT
Constructor and Description |
---|
Session_1_0(Connection_1_0 connection,
SessionEndpoint endpoint) |
public Session_1_0(Connection_1_0 connection, SessionEndpoint endpoint)
public AccessControlContext getAccessControllerContext()
public void remoteLinkCreation(LinkEndpoint endpoint)
remoteLinkCreation
in interface SessionEventListener
public ServerTransaction getTransaction(Binary transactionId)
public void remoteEnd(End end)
remoteEnd
in interface SessionEventListener
public UUID getId()
getId
in interface AMQSessionModel<Session_1_0>
public AMQPConnection<?> getAMQPConnection()
getAMQPConnection
in interface AMQSessionModel<Session_1_0>
public String getClientID()
getClientID
in interface AMQSessionModel<Session_1_0>
public void close()
close
in interface AMQSessionModel<Session_1_0>
protected void performCloseTasks()
public void close(AMQConstant cause, String message)
close
in interface AMQSessionModel<Session_1_0>
public void transportStateChanged()
transportStateChanged
in interface AMQSessionModel<Session_1_0>
public LogSubject getLogSubject()
getLogSubject
in interface AMQSessionModel<Session_1_0>
public void checkTransactionStatus(long openWarn, long openClose, long idleWarn, long idleClose)
AMQSessionModel
checkTransactionStatus
in interface AMQSessionModel<Session_1_0>
openWarn
- time in milliseconds before alerting on open transactionopenClose
- time in milliseconds before closing connection with open transactionidleWarn
- time in milliseconds before alerting on idle transactionidleClose
- time in milliseconds before closing connection with idle transactionpublic void block(AMQQueue queue)
block
in interface AMQSessionModel<Session_1_0>
public void unblock(AMQQueue queue)
unblock
in interface AMQSessionModel<Session_1_0>
public void block()
block
in interface AMQSessionModel<Session_1_0>
public void unblock()
unblock
in interface AMQSessionModel<Session_1_0>
public boolean getBlocking()
getBlocking
in interface AMQSessionModel<Session_1_0>
public Object getConnectionReference()
getConnectionReference
in interface AMQSessionModel<Session_1_0>
public int getUnacknowledgedMessageCount()
getUnacknowledgedMessageCount
in interface AMQSessionModel<Session_1_0>
public Long getTxnCount()
getTxnCount
in interface AMQSessionModel<Session_1_0>
public Long getTxnStart()
getTxnStart
in interface AMQSessionModel<Session_1_0>
public Long getTxnCommits()
getTxnCommits
in interface AMQSessionModel<Session_1_0>
public Long getTxnRejects()
getTxnRejects
in interface AMQSessionModel<Session_1_0>
public int getChannelId()
getChannelId
in interface AMQSessionModel<Session_1_0>
public int getConsumerCount()
getConsumerCount
in interface AMQSessionModel<Session_1_0>
public String toLogString()
LogSubject
toLogString
in interface LogSubject
public int compareTo(AMQSessionModel o)
compareTo
in interface Comparable<AMQSessionModel>
public Connection_1_0 getConnection()
public void addDeleteTask(Action<? super Session_1_0> task)
addDeleteTask
in interface Deletable<Session_1_0>
public void removeDeleteTask(Action<? super Session_1_0> task)
removeDeleteTask
in interface Deletable<Session_1_0>
public Subject getSubject()
public Collection<Consumer<?>> getConsumers()
getConsumers
in interface AMQSessionModel<Session_1_0>
public void addConsumerListener(ConsumerListener listener)
addConsumerListener
in interface AMQSessionModel<Session_1_0>
public void removeConsumerListener(ConsumerListener listener)
removeConsumerListener
in interface AMQSessionModel<Session_1_0>
public void setModelObject(Session<?> session)
setModelObject
in interface AMQSessionModel<Session_1_0>
public Session<?> getModelObject()
getModelObject
in interface AMQSessionModel<Session_1_0>
public long getTransactionStartTime()
AMQSessionModel
getTransactionStartTime
in interface AMQSessionModel<Session_1_0>
public long getTransactionUpdateTime()
AMQSessionModel
getTransactionUpdateTime
in interface AMQSessionModel<Session_1_0>
public boolean processPending()
processPending
in interface AMQSessionModel<Session_1_0>
public void addTicker(Ticker ticker)
addTicker
in interface AMQSessionModel<Session_1_0>
public void removeTicker(Ticker ticker)
removeTicker
in interface AMQSessionModel<Session_1_0>
public void notifyConsumerTargetCurrentStates()
notifyConsumerTargetCurrentStates
in interface AMQSessionModel<Session_1_0>
public void ensureConsumersNoticedStateChange()
ensureConsumersNoticedStateChange
in interface AMQSessionModel<Session_1_0>
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.