public interface ConsumerImpl
Modifier and Type | Interface and Description |
---|---|
static class |
ConsumerImpl.Option |
Modifier and Type | Field and Description |
---|---|
static AtomicLong |
CONSUMER_NUMBER_GENERATOR |
Modifier and Type | Method and Description |
---|---|
boolean |
acquires() |
void |
close() |
void |
externalStateChange() |
void |
flush() |
long |
getBytesOut() |
long |
getConsumerNumber() |
MessageSource |
getMessageSource() |
long |
getMessagesOut() |
String |
getName() |
void |
getSendLock() |
AMQSessionModel |
getSessionModel() |
ConsumerTarget |
getTarget() |
long |
getUnacknowledgedBytes() |
long |
getUnacknowledgedMessages() |
boolean |
isActive() |
boolean |
isClosed() |
boolean |
isSuspended() |
void |
releaseSendLock() |
boolean |
seesRequeues() |
boolean |
trySendLock() |
static final AtomicLong CONSUMER_NUMBER_GENERATOR
void externalStateChange()
ConsumerTarget getTarget()
long getBytesOut()
long getMessagesOut()
long getUnacknowledgedBytes()
long getUnacknowledgedMessages()
AMQSessionModel getSessionModel()
MessageSource getMessageSource()
long getConsumerNumber()
boolean isSuspended()
boolean isClosed()
boolean acquires()
boolean seesRequeues()
void close()
boolean trySendLock()
void getSendLock()
void releaseSendLock()
boolean isActive()
String getName()
void flush()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.