public interface AMQSessionModel<T extends AMQSessionModel<T>> extends Comparable<AMQSessionModel>, Deletable<T>
Comparable
to allow objects to be inserted into a ConcurrentSkipListSet
when monitoring the blocking and blocking of queues/sessions in AMQQueue
.compareTo
addDeleteTask, removeDeleteTask
UUID getId()
AMQPConnection<?> getAMQPConnection()
String getClientID()
void close()
void close(AMQConstant cause, String message)
LogSubject getLogSubject()
void checkTransactionStatus(long openWarn, long openClose, long idleWarn, long idleClose)
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 transactionvoid block(AMQQueue queue)
void unblock(AMQQueue queue)
void block()
void unblock()
boolean getBlocking()
Object getConnectionReference()
int getUnacknowledgedMessageCount()
Long getTxnCount()
Long getTxnStart()
Long getTxnCommits()
Long getTxnRejects()
int getChannelId()
int getConsumerCount()
Collection<Consumer<?>> getConsumers()
void addConsumerListener(ConsumerListener listener)
void removeConsumerListener(ConsumerListener listener)
void setModelObject(Session<?> session)
Session<?> getModelObject()
long getTransactionStartTime()
long getTransactionUpdateTime()
void transportStateChanged()
boolean processPending()
void addTicker(Ticker ticker)
void removeTicker(Ticker ticker)
void notifyConsumerTargetCurrentStates()
void ensureConsumersNoticedStateChange()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.