org.apache.qpid.server.queue

Interface QueueConsumer<X extends QueueConsumer<X>>

All Superinterfaces:

ConfiguredObject<X>, Consumer<X>, ConsumerImpl

public interface QueueConsumer<X extends QueueConsumer<X>>
extends ConsumerImpl, Consumer<X>

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.qpid.server.consumer.ConsumerImpl

ConsumerImpl.Option

Field Summary

Fields inherited from interface org.apache.qpid.server.consumer.ConsumerImpl

CONSUMER_NUMBER_GENERATOR

Fields inherited from interface org.apache.qpid.server.model.Consumer

DISTRIBUTION_MODE, EXCLUSIVE, NO_LOCAL, SELECTOR, SETTLEMENT_MODE, SUSPEND_NOTIFICATION_PERIOD, SUSPEND_NOTIFICATION_PERIOD_DEFAULT

Fields inherited from interface org.apache.qpid.server.model.ConfiguredObject

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

Method Summary

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)

Methods inherited from interface org.apache.qpid.server.consumer.ConsumerImpl

acquires, close, externalStateChange, flush, getBytesOut, getConsumerNumber, getMessageSource, getMessagesOut, getName, getSendLock, getSessionModel, getTarget, getUnacknowledgedBytes, getUnacknowledgedMessages, isActive, isClosed, isSuspended, releaseSendLock, seesRequeues, trySendLock

Methods inherited from interface org.apache.qpid.server.model.Consumer

getBytesOut, getDistributionMode, getMessagesOut, getSelector, getSettlementMode, getUnacknowledgedBytes, getUnacknowledgedMessages, isExclusive, isNoLocal

Methods inherited from interface org.apache.qpid.server.model.ConfiguredObject

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

Method Detail

flushBatched

void flushBatched()

queueEmpty

void queueEmpty()

hasInterest

boolean hasInterest(QueueEntry node)

wouldSuspend

boolean wouldSuspend(QueueEntry entry)

restoreCredit

void restoreCredit(QueueEntry entry)

send

void send(QueueEntry entry,
          boolean batch)

acquisitionRemoved

void acquisitionRemoved(QueueEntry node)

queueDeleted

void queueDeleted()

getQueue

AMQQueue getQueue()

resend

boolean resend(QueueEntry e)

getOwningState

MessageInstance.ConsumerAcquiredState<X> getOwningState()

getQueueContext

org.apache.qpid.server.queue.QueueContext getQueueContext()

awaitCredit

void awaitCredit(QueueEntry entry)