org.apache.qpid.server.queue
Interface QueueEntry
- All Superinterfaces:
- Comparable<QueueEntry>, Filterable
- All Known Implementing Classes:
- QueueEntryImpl
public interface QueueEntry
- extends Comparable<QueueEntry>, Filterable
AVAILABLE_STATE
static final QueueEntry.EntryState AVAILABLE_STATE
DELETED_STATE
static final QueueEntry.EntryState DELETED_STATE
DEQUEUED_STATE
static final QueueEntry.EntryState DEQUEUED_STATE
EXPIRED_STATE
static final QueueEntry.EntryState EXPIRED_STATE
NON_SUBSCRIPTION_ACQUIRED_STATE
static final QueueEntry.EntryState NON_SUBSCRIPTION_ACQUIRED_STATE
getQueue
AMQQueue getQueue()
getMessage
ServerMessage getMessage()
getSize
long getSize()
getDeliveredToConsumer
boolean getDeliveredToConsumer()
expired
boolean expired()
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
isAvailable
boolean isAvailable()
isAcquired
boolean isAcquired()
acquire
boolean acquire()
acquire
boolean acquire(Subscription sub)
delete
boolean delete()
isDeleted
boolean isDeleted()
acquiredBySubscription
boolean acquiredBySubscription()
isAcquiredBy
boolean isAcquiredBy(Subscription subscription)
release
void release()
releaseButRetain
boolean releaseButRetain()
immediateAndNotDelivered
boolean immediateAndNotDelivered()
setRedelivered
void setRedelivered()
isRedelivered
boolean isRedelivered()
- Specified by:
isRedelivered
in interface Filterable
getDeliveredSubscription
Subscription getDeliveredSubscription()
reject
void reject()
reject
void reject(Subscription subscription)
isRejectedBy
boolean isRejectedBy(Subscription subscription)
requeue
void requeue(Subscription subscription)
dequeue
void dequeue()
dispose
void dispose()
discard
void discard()
routeToAlternate
void routeToAlternate()
isQueueDeleted
boolean isQueueDeleted()
addStateChangeListener
void addStateChangeListener(QueueEntry.StateChangeListener listener)
removeStateChangeListener
boolean removeStateChangeListener(QueueEntry.StateChangeListener listener)
Licensed to the Apache Software Foundation