org.apache.qpid.server.queue
Interface QueueEntry

All Superinterfaces:
Comparable<QueueEntry>, Filterable
All Known Implementing Classes:
QueueEntryImpl

public interface QueueEntry
extends Comparable<QueueEntry>, Filterable


Nested Class Summary
static class QueueEntry.AvailableState
           
static class QueueEntry.DeletedState
           
static class QueueEntry.DequeuedState
           
static class QueueEntry.EntryState
           
static class QueueEntry.ExpiredState
           
static class QueueEntry.NonSubscriptionAcquiredState
           
static class QueueEntry.State
           
static interface QueueEntry.StateChangeListener
           
static class QueueEntry.SubscriptionAcquiredState
           
static class QueueEntry.SubscriptionAssignedState
           
 
Field Summary
static QueueEntry.EntryState AVAILABLE_STATE
           
static QueueEntry.EntryState DELETED_STATE
           
static QueueEntry.EntryState DEQUEUED_STATE
           
static QueueEntry.EntryState EXPIRED_STATE
           
static QueueEntry.EntryState NON_SUBSCRIPTION_ACQUIRED_STATE
           
 
Method Summary
 boolean acquire()
           
 boolean acquire(Subscription sub)
           
 boolean acquiredBySubscription()
           
 void addStateChangeListener(QueueEntry.StateChangeListener listener)
           
 boolean delete()
           
 void dequeue()
           
 void discard()
           
 void dispose()
           
 boolean expired()
           
 Subscription getDeliveredSubscription()
           
 boolean getDeliveredToConsumer()
           
 ServerMessage getMessage()
           
 AMQQueue getQueue()
           
 long getSize()
           
 boolean immediateAndNotDelivered()
           
 boolean isAcquired()
           
 boolean isAcquiredBy(Subscription subscription)
           
 boolean isAvailable()
           
 boolean isDeleted()
           
 boolean isQueueDeleted()
           
 boolean isRedelivered()
           
 boolean isRejectedBy(Subscription subscription)
           
 void reject()
           
 void reject(Subscription subscription)
           
 void release()
           
 boolean releaseButRetain()
           
 boolean removeStateChangeListener(QueueEntry.StateChangeListener listener)
           
 void requeue(Subscription subscription)
           
 void routeToAlternate()
           
 void setRedelivered()
           
 
Methods inherited from interface java.lang.Comparable
compareTo
 
Methods inherited from interface org.apache.qpid.server.queue.Filterable
getMessageHeader, isPersistent
 

Field Detail

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
Method Detail

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