public interface ConsumerTarget
Modifier and Type | Interface and Description |
---|---|
static class |
ConsumerTarget.State |
Modifier and Type | Method and Description |
---|---|
void |
acquisitionRemoved(MessageInstance node) |
void |
addStateListener(StateChangeListener<ConsumerTarget,ConsumerTarget.State> listener) |
boolean |
allocateCredit(ServerMessage msg) |
boolean |
close() |
void |
consumerAdded(ConsumerImpl sub) |
void |
consumerRemoved(ConsumerImpl sub) |
void |
flushBatched() |
void |
getSendLock() |
AMQSessionModel |
getSessionModel() |
ConsumerTarget.State |
getState() |
long |
getUnacknowledgedBytes() |
long |
getUnacknowledgedMessages() |
boolean |
hasMessagesToSend() |
boolean |
hasPendingWork() |
boolean |
isSuspended() |
void |
notifyCurrentState() |
boolean |
processPending() |
void |
queueDeleted() |
void |
queueEmpty() |
void |
releaseSendLock() |
void |
removeStateChangeListener(StateChangeListener<ConsumerTarget,ConsumerTarget.State> listener) |
void |
restoreCredit(ServerMessage queueEntry) |
long |
send(ConsumerImpl consumer,
MessageInstance entry,
boolean batch) |
void |
sendNextMessage() |
boolean |
trySendLock() |
void acquisitionRemoved(MessageInstance node)
void removeStateChangeListener(StateChangeListener<ConsumerTarget,ConsumerTarget.State> listener)
boolean processPending()
boolean hasPendingWork()
ConsumerTarget.State getState()
void consumerAdded(ConsumerImpl sub)
void consumerRemoved(ConsumerImpl sub)
void notifyCurrentState()
void addStateListener(StateChangeListener<ConsumerTarget,ConsumerTarget.State> listener)
long getUnacknowledgedBytes()
long getUnacknowledgedMessages()
AMQSessionModel getSessionModel()
long send(ConsumerImpl consumer, MessageInstance entry, boolean batch)
boolean hasMessagesToSend()
void sendNextMessage()
void flushBatched()
void queueDeleted()
void queueEmpty()
boolean allocateCredit(ServerMessage msg)
void restoreCredit(ServerMessage queueEntry)
boolean isSuspended()
boolean close()
boolean trySendLock()
void getSendLock()
void releaseSendLock()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.