org.hornetq.core.server

Interface Queue

All Superinterfaces:

Bindable

All Known Implementing Classes:

LastValueQueue, QueueImpl

public interface Queue
extends Bindable

A Queue

Author:

Tim Fox, Andy Taylor, Clebert Suconic

Method Summary

Modifier and Type	Method and Description
void	acknowledge(MessageReference ref)
void	acknowledge(Transaction tx, MessageReference ref)
void	addConsumer(Consumer consumer)
void	addHead(List<MessageReference> refs)
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 ref)
void	cancel(Transaction tx, MessageReference ref, boolean ignoreRedeliveryCheck)
void	cancelRedistributor()
boolean	changeReferencePriority(long messageID, byte newPriority)
int	changeReferencesPriority(Filter filter, byte newPriority)
boolean	checkRedelivery(MessageReference ref, long timeBase, boolean ignoreRedeliveryDelay)
void	close()
int	deleteAllReferences()
int	deleteAllReferences(int flushLimit)
int	deleteMatchingReferences(Filter filter)
int	deleteMatchingReferences(int flushLImit, Filter filter)
void	deleteQueue()
void	deleteQueue(boolean removeConsumers)
boolean	deleteReference(long messageID)
void	deliverAsync()
void	destroyPaging()
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
boolean	flushExecutor()
void	forceDelivery() This method will make sure that any pending message (including paged message) will be delivered
SimpleString	getAddress()
int	getConsumerCount()
Collection<Consumer>	getConsumers()
ReferenceCounter	getConsumersRefCount()
int	getDeliveringCount()
Map<String,List<MessageReference>>	getDeliveringMessages() Return a Map consisting of consumer.toString and its messages Delivering message is a property of the consumer, this method will aggregate the results per Server's consumer object
Executor	getExecutor()
SimpleString	getExpiryAddress()
Filter	getFilter()
long	getID()
long	getInstantMessageCount() Return the current message count without waiting for scheduled executors to finish
long	getInstantMessagesAdded()
long	getMessageCount() It will wait for up to 10 seconds for a flush on the executors and return the number of messages added.
long	getMessageCount(long timeout) This method will return the messages added after waiting some time on the flush executors.
long	getMessagesAdded() It will wait for up to 10 seconds for a flush on the executors and return the number of messages added.
long	getMessagesAdded(long timeout) This method will return the messages added after waiting some time on the flush executors.
SimpleString	getName()
PageSubscription	getPageSubscription()
float	getRate()
MessageReference	getReference(long id)
int	getScheduledCount()
List<MessageReference>	getScheduledMessages()
boolean	hasMatchingConsumer(ServerMessage message)
boolean	isDirectDeliver()
boolean	isDurable()
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 rejectDuplicates)
int	moveReferences(Filter filter, SimpleString toAddress)
int	moveReferences(int flushLimit, Filter filter, SimpleString toAddress, boolean rejectDuplicates)
void	pause() Pauses the queue.
void	reacknowledge(Transaction tx, MessageReference ref)
void	referenceHandled()
void	reload(MessageReference ref)
void	removeConsumer(Consumer consumer)
MessageReference	removeReferenceWithID(long id)
void	resetAllIterators()
void	resetMessagesAdded()
void	resume() Resumes the delivery of message for the queue.
int	sendMessagesToDeadLetterAddress(Filter filter)
boolean	sendMessageToDeadLetterAddress(long messageID)
void	setConsumersRefCount(HornetQServer server) This will set a reference counter for every consumer present on the queue.
void	setInternalQueue(boolean internalQueue)
LinkedListIterator<MessageReference>	totalIterator()
void	unproposed(SimpleString groupID)

Methods inherited from interface org.hornetq.core.server.Bindable

route

Method Detail

getName

SimpleString getName()

getID

long getID()

getFilter

Filter getFilter()

getPageSubscription

PageSubscription getPageSubscription()

isDurable

boolean isDurable()

isTemporary

boolean isTemporary()

addConsumer

void addConsumer(Consumer consumer)
          throws Exception

Throws:

Exception

removeConsumer

void removeConsumer(Consumer consumer)

getConsumerCount

int getConsumerCount()

setConsumersRefCount

void setConsumersRefCount(HornetQServer server)

This will set a reference counter for every consumer present on the queue. The ReferenceCounter will know what to do when the counter became zeroed. This is used to control what to do with temporary queues, especially on shared subscriptions where the queue needs to be deleted when all the consumers are closed.

getConsumersRefCount

ReferenceCounter getConsumersRefCount()

reload

void reload(MessageReference ref)

addTail

void addTail(MessageReference ref)

addTail

void addTail(MessageReference ref,
             boolean direct)

addHead

void addHead(MessageReference ref)

addHead

void addHead(List<MessageReference> refs)

acknowledge

void acknowledge(MessageReference ref)
          throws Exception

Throws:

Exception

acknowledge

void acknowledge(Transaction tx,
                 MessageReference ref)
          throws Exception

Throws:

Exception

reacknowledge

void reacknowledge(Transaction tx,
                   MessageReference ref)
            throws Exception

Throws:

Exception

cancel

void cancel(Transaction tx,
            MessageReference ref)

cancel

void cancel(Transaction tx,
            MessageReference ref,
            boolean ignoreRedeliveryCheck)

cancel

void cancel(MessageReference reference,
            long timeBase)
     throws Exception

Throws:

Exception

deliverAsync

void deliverAsync()

unproposed

void unproposed(SimpleString groupID)

forceDelivery

void forceDelivery()

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

deleteQueue

void deleteQueue()
          throws Exception

Throws:

Exception

deleteQueue

void deleteQueue(boolean removeConsumers)
          throws Exception

Throws:

Exception

destroyPaging

void destroyPaging()
            throws Exception

Throws:

Exception

getMessageCount

long getMessageCount()

It will wait for up to 10 seconds for a flush on the executors and return the number of messages added. if the executor is busy for any reason (say an unbehaved consumer) we will just return the current value.

Returns:

getMessageCount

long getMessageCount(long timeout)

This method will return the messages added after waiting some time on the flush executors. If the executor couldn't be flushed within the timeout we will just return the current value without any warn

Parameters:

timeout - Time to wait for current executors to finish in milliseconds.

Returns:

getInstantMessageCount

long getInstantMessageCount()

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

getDeliveringCount

int getDeliveringCount()

referenceHandled

void referenceHandled()

getScheduledCount

int getScheduledCount()

getScheduledMessages

List<MessageReference> getScheduledMessages()

getDeliveringMessages

Map<String,List<MessageReference>> getDeliveringMessages()

Return a Map consisting of consumer.toString and its messages Delivering message is a property of the consumer, this method will aggregate the results per Server's consumer object

Returns:

getMessagesAdded

long getMessagesAdded()

It will wait for up to 10 seconds for a flush on the executors and return the number of messages added. if the executor is busy for any reason (say an unbehaved consumer) we will just return the current value.

Returns:

getMessagesAdded

long getMessagesAdded(long timeout)

This method will return the messages added after waiting some time on the flush executors. If the executor couldn't be flushed within the timeout we will just return the current value without any warn

Parameters:

timeout - Time to wait for current executors to finish in milliseconds.

Returns:

getInstantMessagesAdded

long getInstantMessagesAdded()

removeReferenceWithID

MessageReference removeReferenceWithID(long id)
                                throws Exception

Throws:

Exception

getReference

MessageReference getReference(long id)

deleteAllReferences

int deleteAllReferences()
                 throws Exception

Throws:

Exception

deleteAllReferences

int deleteAllReferences(int flushLimit)
                 throws Exception

Throws:

Exception

deleteReference

boolean deleteReference(long messageID)
                 throws Exception

Throws:

Exception

deleteMatchingReferences

int deleteMatchingReferences(Filter filter)
                      throws Exception

Throws:

Exception

deleteMatchingReferences

int deleteMatchingReferences(int flushLImit,
                             Filter filter)
                      throws Exception

Throws:

Exception

expireReference

boolean expireReference(long messageID)
                 throws Exception

Throws:

Exception

expireReferences

int expireReferences(Filter filter)
              throws Exception

Expire all the references in the queue which matches the filter

Throws:

Exception

expireReferences

void expireReferences()
               throws Exception

Throws:

Exception

expire

void expire(MessageReference ref)
     throws Exception

Throws:

Exception

sendMessageToDeadLetterAddress

boolean sendMessageToDeadLetterAddress(long messageID)
                                throws Exception

Throws:

Exception

sendMessagesToDeadLetterAddress

int sendMessagesToDeadLetterAddress(Filter filter)
                             throws Exception

Throws:

Exception

changeReferencePriority

boolean changeReferencePriority(long messageID,
                                byte newPriority)
                         throws Exception

Throws:

Exception

changeReferencesPriority

int changeReferencesPriority(Filter filter,
                             byte newPriority)
                      throws Exception

Throws:

Exception

moveReference

boolean moveReference(long messageID,
                      SimpleString toAddress)
               throws Exception

Throws:

Exception

moveReference

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

Throws:

Exception

moveReferences

int moveReferences(Filter filter,
                   SimpleString toAddress)
            throws Exception

Throws:

Exception

moveReferences

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

Throws:

Exception

addRedistributor

void addRedistributor(long delay)

cancelRedistributor

void cancelRedistributor()
                  throws Exception

Throws:

Exception

hasMatchingConsumer

boolean hasMatchingConsumer(ServerMessage message)

getConsumers

Collection<Consumer> getConsumers()

checkRedelivery

boolean checkRedelivery(MessageReference ref,
                        long timeBase,
                        boolean ignoreRedeliveryDelay)
                 throws Exception

Throws:

Exception

iterator

LinkedListIterator<MessageReference> iterator()

totalIterator

LinkedListIterator<MessageReference> totalIterator()

getExpiryAddress

SimpleString getExpiryAddress()

pause

void pause()

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()

resume

void resume()

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()

isPaused

boolean isPaused()

Returns:

true if paused, false otherwise.

getExecutor

Executor getExecutor()

resetAllIterators

void resetAllIterators()

flushExecutor

boolean flushExecutor()

close

void close()
    throws Exception

Throws:

Exception

isDirectDeliver

boolean isDirectDeliver()

getAddress

SimpleString getAddress()

isInternalQueue

boolean isInternalQueue()

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

Returns:

setInternalQueue

void setInternalQueue(boolean internalQueue)

resetMessagesAdded

void resetMessagesAdded()

getRate

float getRate()