public abstract class OrderedQueueEntry extends QueueEntryImpl
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
Constructor and Description |
---|
OrderedQueueEntry(OrderedQueueEntryList queueEntryList) |
OrderedQueueEntry(OrderedQueueEntryList queueEntryList,
ServerMessage message,
MessageEnqueueRecord messageEnqueueRecord) |
Modifier and Type | Method and Description |
---|---|
OrderedQueueEntry |
getNextNode() |
OrderedQueueEntry |
getNextValidEntry() |
acquire, acquire, acquiredByConsumer, acquireOrSteal, addStateChangeListener, asFilterable, checkHeld, compareTo, decrementDeliveryCount, delete, expired, getAcquiringConsumer, getDeliveredConsumer, getDeliveredToConsumer, getDeliveryCount, getEnqueueRecord, getEntryId, getInstanceProperties, getMaximumDeliveryCount, getMessage, getOwningResource, getQueue, getQueueEntryList, getSize, incrementDeliveryCount, isAcquired, isAcquiredBy, isAvailable, isDeleted, isQueueDeleted, isRedelivered, isRejectedBy, lockAcquisition, newMessageReference, onDelete, reject, release, release, removeAcquisitionFromConsumer, removeStateChangeListener, resend, routeToAlternate, setEntryId, setExpiration, setRedelivered, toString, unlockAcquisition
public OrderedQueueEntry(OrderedQueueEntryList queueEntryList)
public OrderedQueueEntry(OrderedQueueEntryList queueEntryList, ServerMessage message, MessageEnqueueRecord messageEnqueueRecord)
public OrderedQueueEntry getNextNode()
public OrderedQueueEntry getNextValidEntry()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.