public interface QueueConsumer<X extends QueueConsumer<X>> extends ConsumerImpl, Consumer<X>
ConsumerImpl.Option
CONSUMER_NUMBER_GENERATOR
DISTRIBUTION_MODE, EXCLUSIVE, NO_LOCAL, SELECTOR, SETTLEMENT_MODE, SUSPEND_NOTIFICATION_PERIOD, SUSPEND_NOTIFICATION_PERIOD_DEFAULT
CONTEXT, CREATED_BY, CREATED_TIME, DESCRIPTION, DESIRED_STATE, DURABLE, ID, LAST_UPDATED_BY, LAST_UPDATED_TIME, LIFETIME_POLICY, NAME, OVER_SIZED_ATTRIBUTE_ALTERNATIVE_TEXT, STATE, TYPE
Modifier and Type | Method and Description |
---|---|
void |
acquisitionRemoved(QueueEntry node) |
void |
awaitCredit(QueueEntry entry) |
void |
flushBatched() |
MessageInstance.ConsumerAcquiredState<X> |
getOwningState() |
AMQQueue |
getQueue() |
org.apache.qpid.server.queue.QueueContext |
getQueueContext() |
boolean |
hasInterest(QueueEntry node) |
void |
queueDeleted() |
void |
queueEmpty() |
boolean |
resend(QueueEntry e) |
void |
restoreCredit(QueueEntry entry) |
void |
send(QueueEntry entry,
boolean batch) |
boolean |
wouldSuspend(QueueEntry entry) |
acquires, close, externalStateChange, flush, getBytesOut, getConsumerNumber, getMessageSource, getMessagesOut, getName, getSendLock, getSessionModel, getTarget, getUnacknowledgedBytes, getUnacknowledgedMessages, isActive, isClosed, isSuspended, releaseSendLock, seesRequeues, trySendLock
getBytesOut, getDistributionMode, getMessagesOut, getSelector, getSettlementMode, getUnacknowledgedBytes, getUnacknowledgedMessages, isExclusive, isNoLocal
addChangeListener, asObjectRecord, close, closeAsync, createChild, createChildAsync, decryptSecrets, delete, deleteAsync, findConfiguredObject, getActualAttributes, getAttainedChildById, getAttainedChildByName, getAttribute, getAttributeNames, getCategoryClass, getChildById, getChildByName, getChildExecutor, getChildren, getContext, getContextKeys, getContextValue, getContextValue, getCreatedBy, getCreatedTime, getDescription, getDesiredState, getId, getLastOpenedTime, getLastUpdatedBy, getLastUpdatedTime, getLifetimePolicy, getModel, getName, getObjectFactory, getParent, getState, getStatistics, getTaskExecutor, getType, getTypeClass, isDurable, managesChildStorage, open, openAsync, removeChangeListener, setAttribute, setAttributes, setAttributesAsync
void flushBatched()
void queueEmpty()
boolean hasInterest(QueueEntry node)
boolean wouldSuspend(QueueEntry entry)
void restoreCredit(QueueEntry entry)
void send(QueueEntry entry, boolean batch)
void acquisitionRemoved(QueueEntry node)
void queueDeleted()
AMQQueue getQueue()
boolean resend(QueueEntry e)
MessageInstance.ConsumerAcquiredState<X> getOwningState()
org.apache.qpid.server.queue.QueueContext getQueueContext()
void awaitCredit(QueueEntry entry)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.