org.apache.qpid.server.queue

Class QueueEntryImpl

java.lang.Object

org.apache.qpid.server.queue.QueueEntryImpl

All Implemented Interfaces:

Comparable<QueueEntry>, MessageInstance, QueueEntry

Direct Known Subclasses:

OrderedQueueEntry, SortedQueueEntry

public abstract class QueueEntryImpl
extends Object
implements QueueEntry

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.qpid.server.message.MessageInstance

MessageInstance.AvailableState, MessageInstance.ConsumerAcquiredState<C extends ConsumerImpl>, MessageInstance.DeletedState, MessageInstance.DequeuedState, MessageInstance.EntryState, MessageInstance.LockedAcquiredState<C extends ConsumerImpl>, MessageInstance.NonConsumerAcquiredState, MessageInstance.State

Field Summary

Fields inherited from interface org.apache.qpid.server.message.MessageInstance

AVAILABLE_STATE, DELETED_STATE, DEQUEUED_STATE, NON_CONSUMER_ACQUIRED_STATE

Constructor Summary

Constructors

Constructor and Description
QueueEntryImpl(QueueEntryList queueEntryList)
QueueEntryImpl(QueueEntryList queueEntryList, ServerMessage message, long entryId, MessageEnqueueRecord enqueueRecord)
QueueEntryImpl(QueueEntryList queueEntryList, ServerMessage message, MessageEnqueueRecord enqueueRecord)

Method Summary

Modifier and Type	Method and Description
boolean	acquire()
boolean	acquire(ConsumerImpl sub)
boolean	acquiredByConsumer()
boolean	acquireOrSteal(Runnable delayedAcquisitionTask)
void	addStateChangeListener(StateChangeListener<? super MessageInstance,MessageInstance.State> listener)
Filterable	asFilterable()
boolean	checkHeld(long evaluationTime)
int	compareTo(QueueEntry o)
void	decrementDeliveryCount()
void	delete()
boolean	expired()
ConsumerImpl	getAcquiringConsumer()
QueueConsumer	getDeliveredConsumer()
boolean	getDeliveredToConsumer()
int	getDeliveryCount() Number of times this queue entry has been delivered.
MessageEnqueueRecord	getEnqueueRecord()
protected long	getEntryId()
InstanceProperties	getInstanceProperties()
int	getMaximumDeliveryCount()
ServerMessage	getMessage()
TransactionLogResource	getOwningResource()
AMQQueue	getQueue()
QueueEntryList	getQueueEntryList()
long	getSize()
void	incrementDeliveryCount()
boolean	isAcquired()
boolean	isAcquiredBy(ConsumerImpl consumer)
boolean	isAvailable()
boolean	isDeleted()
boolean	isQueueDeleted()
boolean	isRedelivered()
boolean	isRejectedBy(ConsumerImpl consumer)
boolean	lockAcquisition(ConsumerImpl consumer)
MessageReference	newMessageReference()
protected void	onDelete()
void	reject()
void	release()
void	release(ConsumerImpl consumer)
boolean	removeAcquisitionFromConsumer(ConsumerImpl consumer)
boolean	removeStateChangeListener(StateChangeListener<? super MessageInstance,MessageInstance.State> listener)
boolean	resend()
int	routeToAlternate(Action<? super MessageInstance> action, ServerTransaction txn)
protected void	setEntryId(long entryId)
void	setExpiration(long expiration)
void	setRedelivered()
String	toString()
boolean	unlockAcquisition()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.qpid.server.queue.QueueEntry

getNextNode, getNextValidEntry

Constructor Detail

QueueEntryImpl

public QueueEntryImpl(QueueEntryList queueEntryList)

QueueEntryImpl

public QueueEntryImpl(QueueEntryList queueEntryList,
                      ServerMessage message,
                      long entryId,
                      MessageEnqueueRecord enqueueRecord)

QueueEntryImpl

public QueueEntryImpl(QueueEntryList queueEntryList,
                      ServerMessage message,
                      MessageEnqueueRecord enqueueRecord)

Method Detail

setExpiration

public void setExpiration(long expiration)

Specified by:

setExpiration in interface QueueEntry

getInstanceProperties

public InstanceProperties getInstanceProperties()

Specified by:

getInstanceProperties in interface MessageInstance

setEntryId

protected void setEntryId(long entryId)

getEntryId

protected long getEntryId()

getQueue

public AMQQueue getQueue()

Specified by:

getQueue in interface QueueEntry

getMessage

public ServerMessage getMessage()

Specified by:

getMessage in interface MessageInstance

getSize

public long getSize()

Specified by:

getSize in interface QueueEntry

getDeliveredToConsumer

public boolean getDeliveredToConsumer()

Specified by:

getDeliveredToConsumer in interface MessageInstance

expired

public boolean expired()

Specified by:

expired in interface MessageInstance

isAvailable

public boolean isAvailable()

Specified by:

isAvailable in interface MessageInstance

isAcquired

public boolean isAcquired()

Specified by:

isAcquired in interface MessageInstance

acquire

public boolean acquire()

Specified by:

acquire in interface MessageInstance

acquireOrSteal

public boolean acquireOrSteal(Runnable delayedAcquisitionTask)

Specified by:

acquireOrSteal in interface QueueEntry

acquire

public boolean acquire(ConsumerImpl sub)

Specified by:

acquire in interface MessageInstance

lockAcquisition

public boolean lockAcquisition(ConsumerImpl consumer)

Specified by:

lockAcquisition in interface MessageInstance

unlockAcquisition

public boolean unlockAcquisition()

Specified by:

unlockAcquisition in interface MessageInstance

acquiredByConsumer

public boolean acquiredByConsumer()

Specified by:

acquiredByConsumer in interface MessageInstance

getAcquiringConsumer

public ConsumerImpl getAcquiringConsumer()

Specified by:

getAcquiringConsumer in interface MessageInstance

isAcquiredBy

public boolean isAcquiredBy(ConsumerImpl consumer)

Specified by:

isAcquiredBy in interface MessageInstance

removeAcquisitionFromConsumer

public boolean removeAcquisitionFromConsumer(ConsumerImpl consumer)

Specified by:

removeAcquisitionFromConsumer in interface MessageInstance

release

public void release()

Specified by:

release in interface MessageInstance

release

public void release(ConsumerImpl consumer)

Specified by:

release in interface MessageInstance

checkHeld

public boolean checkHeld(long evaluationTime)

Specified by:

checkHeld in interface QueueEntry

getDeliveredConsumer

public QueueConsumer getDeliveredConsumer()

Specified by:

getDeliveredConsumer in interface MessageInstance

Specified by:

getDeliveredConsumer in interface QueueEntry

reject

public void reject()

Specified by:

reject in interface MessageInstance

isRejectedBy

public boolean isRejectedBy(ConsumerImpl consumer)

Specified by:

isRejectedBy in interface MessageInstance

delete

public void delete()

Specified by:

delete in interface MessageInstance

routeToAlternate

public int routeToAlternate(Action<? super MessageInstance> action,
                            ServerTransaction txn)

Specified by:

routeToAlternate in interface MessageInstance

isQueueDeleted

public boolean isQueueDeleted()

Specified by:

isQueueDeleted in interface QueueEntry

addStateChangeListener

public void addStateChangeListener(StateChangeListener<? super MessageInstance,MessageInstance.State> listener)

Specified by:

addStateChangeListener in interface MessageInstance

removeStateChangeListener

public boolean removeStateChangeListener(StateChangeListener<? super MessageInstance,MessageInstance.State> listener)

Specified by:

removeStateChangeListener in interface MessageInstance

compareTo

public int compareTo(QueueEntry o)

Specified by:

compareTo in interface Comparable<QueueEntry>

onDelete

protected void onDelete()

getQueueEntryList

public QueueEntryList getQueueEntryList()

isDeleted

public boolean isDeleted()

Specified by:

isDeleted in interface MessageInstance

getDeliveryCount

public int getDeliveryCount()

Description copied from interface: MessageInstance

Number of times this queue entry has been delivered.

Specified by:

getDeliveryCount in interface MessageInstance

Returns:

delivery count

getMaximumDeliveryCount

public int getMaximumDeliveryCount()

Specified by:

getMaximumDeliveryCount in interface MessageInstance

incrementDeliveryCount

public void incrementDeliveryCount()

Specified by:

incrementDeliveryCount in interface MessageInstance

decrementDeliveryCount

public void decrementDeliveryCount()

Specified by:

decrementDeliveryCount in interface MessageInstance

asFilterable

public Filterable asFilterable()

Specified by:

asFilterable in interface MessageInstance

toString

public String toString()

Overrides:

toString in class Object

resend

public boolean resend()

Specified by:

resend in interface MessageInstance

getOwningResource

public TransactionLogResource getOwningResource()

Specified by:

getOwningResource in interface MessageInstance

setRedelivered

public void setRedelivered()

Specified by:

setRedelivered in interface MessageInstance

isRedelivered

public boolean isRedelivered()

Specified by:

isRedelivered in interface MessageInstance

newMessageReference

public MessageReference newMessageReference()

Specified by:

newMessageReference in interface QueueEntry

getEnqueueRecord

public MessageEnqueueRecord getEnqueueRecord()

Specified by:

getEnqueueRecord in interface MessageInstance