public interface QueueEntry extends MessageInstance, Comparable<QueueEntry>
MessageInstance.AvailableState, MessageInstance.ConsumerAcquiredState<C extends ConsumerImpl>, MessageInstance.DeletedState, MessageInstance.DequeuedState, MessageInstance.EntryState, MessageInstance.LockedAcquiredState<C extends ConsumerImpl>, MessageInstance.NonConsumerAcquiredState, MessageInstance.State
AVAILABLE_STATE, DELETED_STATE, DEQUEUED_STATE, NON_CONSUMER_ACQUIRED_STATE
Modifier and Type | Method and Description |
---|---|
boolean |
acquireOrSteal(Runnable delayedAcquisitionTask) |
boolean |
checkHeld(long evaluationTime) |
QueueConsumer |
getDeliveredConsumer() |
QueueEntry |
getNextNode() |
QueueEntry |
getNextValidEntry() |
AMQQueue |
getQueue() |
long |
getSize() |
boolean |
isQueueDeleted() |
MessageReference |
newMessageReference() |
void |
setExpiration(long calculatedExpiration) |
acquire, acquire, acquiredByConsumer, addStateChangeListener, asFilterable, decrementDeliveryCount, delete, expired, getAcquiringConsumer, getDeliveredToConsumer, getDeliveryCount, getEnqueueRecord, getInstanceProperties, getMaximumDeliveryCount, getMessage, getOwningResource, incrementDeliveryCount, isAcquired, isAcquiredBy, isAvailable, isDeleted, isRedelivered, isRejectedBy, lockAcquisition, reject, release, release, removeAcquisitionFromConsumer, removeStateChangeListener, resend, routeToAlternate, setRedelivered, unlockAcquisition
compareTo
AMQQueue getQueue()
long getSize()
boolean acquireOrSteal(Runnable delayedAcquisitionTask)
QueueConsumer getDeliveredConsumer()
getDeliveredConsumer
in interface MessageInstance
boolean isQueueDeleted()
QueueEntry getNextNode()
QueueEntry getNextValidEntry()
void setExpiration(long calculatedExpiration)
MessageReference newMessageReference()
boolean checkHeld(long evaluationTime)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.