org.hornetq.core.server.impl

Class QueueImpl

java.lang.Object

org.hornetq.core.server.impl.QueueImpl

All Implemented Interfaces:

Bindable, Queue

Direct Known Subclasses:

LastValueQueue

public class QueueImpl
extends Object
implements Queue

Implementation of a Queue Completely non blocking between adding to queue and delivering to consumers.

Author:

Tim Fox, Andy Taylor, Jeff Mesnil, Clebert Suconic

Field Summary

Fields

Modifier and Type	Field and Description
static int	CHECK_QUEUE_SIZE_PERIOD
protected AtomicInteger	deliveringCount
static int	MAX_DELIVERIES_IN_LOOP
static int	NUM_PRIORITIES
static int	REDISTRIBUTOR_BATCH_SIZE

Constructor Summary

Constructors

Constructor and Description
QueueImpl(long id, SimpleString address, SimpleString name, Filter filter, boolean durable, boolean temporary, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, Executor executor)
QueueImpl(long id, SimpleString address, SimpleString name, Filter filter, PageSubscription pageSubscription, boolean durable, boolean temporary, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, Executor executor)

Method Summary

Methods

Modifier and Type	Method and Description
void	acknowledge(MessageReference ref)
void	acknowledge(Transaction tx, MessageReference ref)
void	addConsumer(Consumer consumer)
void	addHead(MessageReference ref)
void	addRedistributor(long delay)
void	addTail(MessageReference ref)
void	addTail(MessageReference ref, boolean direct)
void	cancel(MessageReference reference, long timeBase)
void	cancel(Transaction tx, MessageReference reference)
void	cancelRedistributor()
boolean	changeReferencePriority(long messageID, byte newPriority)
int	changeReferencesPriority(Filter filter, byte newPriority)
boolean	checkRedelivery(MessageReference reference, long timeBase)
void	close()
String	debug()
int	deleteAllReferences()
int	deleteMatchingReferences(Filter filter)
boolean	deleteReference(long messageID)
void	deliverAsync()
void	deliverNow()
boolean	equals(Object other)
void	expire(MessageReference ref)
boolean	expireReference(long messageID)
void	expireReferences()
int	expireReferences(Filter filter) Expire all the references in the queue which matches the filter
protected void	finalize()
boolean	flushExecutor()
void	forceDelivery() This method will make sure that any pending message (including paged message) will be delivered
SimpleString	getAddress()
int	getConsumerCount()
Set<Consumer>	getConsumers()
int	getDeliveringCount()
Executor	getExecutor()
Filter	getFilter()
long	getID()
long	getInstantMessageCount() Return the current message count without waiting for scheduled executors to finish
long	getInstantMessagesAdded()
long	getMessageCount()
long	getMessagesAdded()
SimpleString	getName()
int	getNumberOfReferences() Used on testing only
PageSubscription	getPageSubscription()
MessageReference	getReference(long id)
SimpleString	getRoutingName()
int	getScheduledCount()
List<MessageReference>	getScheduledMessages()
SimpleString	getUniqueName()
int	hashCode()
boolean	hasMatchingConsumer(ServerMessage message)
boolean	isDirectDeliver()
boolean	isDurable()
boolean	isExclusive()
boolean	isInternalQueue() We can't send stuff to DLQ on queues used on clustered-bridge-communication
boolean	isPaused()
boolean	isTemporary()
LinkedListIterator<MessageReference>	iterator()
boolean	moveReference(long messageID, SimpleString toAddress)
boolean	moveReference(long messageID, SimpleString toAddress, boolean rejectDuplicate)
int	moveReferences(Filter filter, SimpleString toAddress)
int	moveReferences(Filter filter, SimpleString toAddress, boolean rejectDuplicates)
void	pause() Pauses the queue.
protected void	postAcknowledge(MessageReference ref)
void	reacknowledge(Transaction tx, MessageReference ref)
protected void	refAdded(MessageReference ref)
void	referenceHandled()
void	reload(MessageReference ref)
void	removeConsumer(Consumer consumer)
MessageReference	removeReferenceWithID(long id)
void	resetAllIterators()
void	resume() Resumes the delivery of message for the queue.
void	route(ServerMessage message, RoutingContext context)
int	sendMessagesToDeadLetterAddress(Filter filter)
boolean	sendMessageToDeadLetterAddress(long messageID)
void	setExpiryAddress(SimpleString expiryAddress)
void	setInternalQueue(boolean internalQueue)
String	toString()

Methods inherited from class java.lang.Object

clone, getClass, notify, notifyAll, wait, wait, wait

Field Detail

REDISTRIBUTOR_BATCH_SIZE

public static final int REDISTRIBUTOR_BATCH_SIZE

See Also:

Constant Field Values

NUM_PRIORITIES

public static final int NUM_PRIORITIES

See Also:

Constant Field Values

MAX_DELIVERIES_IN_LOOP

public static final int MAX_DELIVERIES_IN_LOOP

See Also:

Constant Field Values

CHECK_QUEUE_SIZE_PERIOD

public static final int CHECK_QUEUE_SIZE_PERIOD

See Also:

Constant Field Values

deliveringCount

protected final AtomicInteger deliveringCount

Constructor Detail

QueueImpl

public QueueImpl(long id,
         SimpleString address,
         SimpleString name,
         Filter filter,
         boolean durable,
         boolean temporary,
         ScheduledExecutorService scheduledExecutor,
         PostOffice postOffice,
         StorageManager storageManager,
         HierarchicalRepository<AddressSettings> addressSettingsRepository,
         Executor executor)

QueueImpl

public QueueImpl(long id,
         SimpleString address,
         SimpleString name,
         Filter filter,
         PageSubscription pageSubscription,
         boolean durable,
         boolean temporary,
         ScheduledExecutorService scheduledExecutor,
         PostOffice postOffice,
         StorageManager storageManager,
         HierarchicalRepository<AddressSettings> addressSettingsRepository,
         Executor executor)

Method Detail

debug

public String debug()

getRoutingName

public SimpleString getRoutingName()

getUniqueName

public SimpleString getUniqueName()

isExclusive

public boolean isExclusive()

route

public void route(ServerMessage message,
         RoutingContext context)
           throws Exception

Specified by:

route in interface Bindable

Throws:

Exception

isDurable

public boolean isDurable()

Specified by:

isDurable in interface Queue

isTemporary

public boolean isTemporary()

Specified by:

isTemporary in interface Queue

getName

public SimpleString getName()

Specified by:

getName in interface Queue

getAddress

public SimpleString getAddress()

Specified by:

getAddress in interface Queue

getID

public long getID()

Specified by:

getID in interface Queue

getPageSubscription

public PageSubscription getPageSubscription()

Specified by:

getPageSubscription in interface Queue

getFilter

public Filter getFilter()

Specified by:

getFilter in interface Queue

addHead

public void addHead(MessageReference ref)

Specified by:

addHead in interface Queue

reload

public void reload(MessageReference ref)

Specified by:

reload in interface Queue

addTail

public void addTail(MessageReference ref)

Specified by:

addTail in interface Queue

addTail

public void addTail(MessageReference ref,
           boolean direct)

Specified by:

addTail in interface Queue

forceDelivery

public void forceDelivery()

Description copied from interface: Queue

This method will make sure that any pending message (including paged message) will be delivered

Specified by:

forceDelivery in interface Queue

deliverAsync

public void deliverAsync()

Specified by:

deliverAsync in interface Queue

close

public void close()
           throws Exception

Specified by:

close in interface Queue

Throws:

Exception

getExecutor

public Executor getExecutor()

Specified by:

getExecutor in interface Queue

deliverNow

public void deliverNow()

flushExecutor

public boolean flushExecutor()

Specified by:

flushExecutor in interface Queue

addConsumer

public void addConsumer(Consumer consumer)
                 throws Exception

Specified by:

addConsumer in interface Queue

Throws:

Exception

removeConsumer

public void removeConsumer(Consumer consumer)
                    throws Exception

Specified by:

removeConsumer in interface Queue

Throws:

Exception

addRedistributor

public void addRedistributor(long delay)

Specified by:

addRedistributor in interface Queue

cancelRedistributor

public void cancelRedistributor()
                         throws Exception

Specified by:

cancelRedistributor in interface Queue

Throws:

Exception

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

getConsumerCount

public int getConsumerCount()

Specified by:

getConsumerCount in interface Queue

getConsumers

public Set<Consumer> getConsumers()

Specified by:

getConsumers in interface Queue

hasMatchingConsumer

public boolean hasMatchingConsumer(ServerMessage message)

Specified by:

hasMatchingConsumer in interface Queue

iterator

public LinkedListIterator<MessageReference> iterator()

Specified by:

iterator in interface Queue

removeReferenceWithID

public MessageReference removeReferenceWithID(long id)
                                       throws Exception

Specified by:

removeReferenceWithID in interface Queue

Throws:

Exception

getReference

public MessageReference getReference(long id)

Specified by:

getReference in interface Queue

getMessageCount

public long getMessageCount()

Specified by:

getMessageCount in interface Queue

getInstantMessageCount

public long getInstantMessageCount()

Description copied from interface: Queue

Return the current message count without waiting for scheduled executors to finish

Specified by:

getInstantMessageCount in interface Queue

getScheduledCount

public int getScheduledCount()

Specified by:

getScheduledCount in interface Queue

getScheduledMessages

public List<MessageReference> getScheduledMessages()

Specified by:

getScheduledMessages in interface Queue

getDeliveringCount

public int getDeliveringCount()

Specified by:

getDeliveringCount in interface Queue

acknowledge

public void acknowledge(MessageReference ref)
                 throws Exception

Specified by:

acknowledge in interface Queue

Throws:

Exception

acknowledge

public void acknowledge(Transaction tx,
               MessageReference ref)
                 throws Exception

Specified by:

acknowledge in interface Queue

Throws:

Exception

reacknowledge

public void reacknowledge(Transaction tx,
                 MessageReference ref)
                   throws Exception

Specified by:

reacknowledge in interface Queue

Throws:

Exception

cancel

public void cancel(Transaction tx,
          MessageReference reference)

Specified by:

cancel in interface Queue

cancel

public void cancel(MessageReference reference,
          long timeBase)
            throws Exception

Specified by:

cancel in interface Queue

Throws:

Exception

expire

public void expire(MessageReference ref)
            throws Exception

Specified by:

expire in interface Queue

Throws:

Exception

setExpiryAddress

public void setExpiryAddress(SimpleString expiryAddress)

Specified by:

setExpiryAddress in interface Queue

referenceHandled

public void referenceHandled()

Specified by:

referenceHandled in interface Queue

getMessagesAdded

public long getMessagesAdded()

Specified by:

getMessagesAdded in interface Queue

getInstantMessagesAdded

public long getInstantMessagesAdded()

Specified by:

getInstantMessagesAdded in interface Queue

deleteAllReferences

public int deleteAllReferences()
                        throws Exception

Specified by:

deleteAllReferences in interface Queue

Throws:

Exception

deleteMatchingReferences

public int deleteMatchingReferences(Filter filter)
                             throws Exception

Specified by:

deleteMatchingReferences in interface Queue

Throws:

Exception

deleteReference

public boolean deleteReference(long messageID)
                        throws Exception

Specified by:

deleteReference in interface Queue

Throws:

Exception

expireReference

public boolean expireReference(long messageID)
                        throws Exception

Specified by:

expireReference in interface Queue

Throws:

Exception

expireReferences

public int expireReferences(Filter filter)
                     throws Exception

Description copied from interface: Queue

Expire all the references in the queue which matches the filter

Specified by:

expireReferences in interface Queue

Throws:

Exception

expireReferences

public void expireReferences()
                      throws Exception

Specified by:

expireReferences in interface Queue

Throws:

Exception

sendMessageToDeadLetterAddress

public boolean sendMessageToDeadLetterAddress(long messageID)
                                       throws Exception

Specified by:

sendMessageToDeadLetterAddress in interface Queue

Throws:

Exception

sendMessagesToDeadLetterAddress

public int sendMessagesToDeadLetterAddress(Filter filter)
                                    throws Exception

Specified by:

sendMessagesToDeadLetterAddress in interface Queue

Throws:

Exception

moveReference

public boolean moveReference(long messageID,
                    SimpleString toAddress)
                      throws Exception

Specified by:

moveReference in interface Queue

Throws:

Exception

moveReference

public boolean moveReference(long messageID,
                    SimpleString toAddress,
                    boolean rejectDuplicate)
                      throws Exception

Specified by:

moveReference in interface Queue

Throws:

Exception

moveReferences

public int moveReferences(Filter filter,
                 SimpleString toAddress)
                   throws Exception

Specified by:

moveReferences in interface Queue

Throws:

Exception

moveReferences

public int moveReferences(Filter filter,
                 SimpleString toAddress,
                 boolean rejectDuplicates)
                   throws Exception

Specified by:

moveReferences in interface Queue

Throws:

Exception

changeReferencePriority

public boolean changeReferencePriority(long messageID,
                              byte newPriority)
                                throws Exception

Specified by:

changeReferencePriority in interface Queue

Throws:

Exception

changeReferencesPriority

public int changeReferencesPriority(Filter filter,
                           byte newPriority)
                             throws Exception

Specified by:

changeReferencesPriority in interface Queue

Throws:

Exception

resetAllIterators

public void resetAllIterators()

Specified by:

resetAllIterators in interface Queue

pause

public void pause()

Description copied from interface: Queue

Pauses the queue. It will receive messages but won't give them to the consumers until resumed. If a queue is paused, pausing it again will only throw a warning. To check if a queue is paused, invoke isPaused()

Specified by:

pause in interface Queue

resume

public void resume()

Description copied from interface: Queue

Resumes the delivery of message for the queue. If a queue is resumed, resuming it again will only throw a warning. To check if a queue is resumed, invoke isPaused()

Specified by:

resume in interface Queue

isPaused

public boolean isPaused()

Specified by:

isPaused in interface Queue

Returns:

true if paused, false otherwise.

isDirectDeliver

public boolean isDirectDeliver()

Specified by:

isDirectDeliver in interface Queue

isInternalQueue

public boolean isInternalQueue()

Description copied from interface: Queue

We can't send stuff to DLQ on queues used on clustered-bridge-communication

Specified by:

isInternalQueue in interface Queue

Returns:

the internalQueue

setInternalQueue

public void setInternalQueue(boolean internalQueue)

Specified by:

setInternalQueue in interface Queue

Parameters:

internalQueue - the internalQueue to set

equals

public boolean equals(Object other)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

refAdded

protected void refAdded(MessageReference ref)

Parameters:

ref -

checkRedelivery

public boolean checkRedelivery(MessageReference reference,
                      long timeBase)
                        throws Exception

Specified by:

checkRedelivery in interface Queue

Throws:

Exception

getNumberOfReferences

public int getNumberOfReferences()

Used on testing only

postAcknowledge

protected void postAcknowledge(MessageReference ref)