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

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 ref)
void	cancelRedistributor()
boolean	changeReferencePriority(long messageID, byte newPriority)
int	changeReferencesPriority(Filter filter, byte newPriority)
boolean	checkRedelivery(MessageReference ref, long timeBase)
void	close()
int	deleteAllReferences()
int	deleteMatchingReferences(Filter filter)
boolean	deleteReference(long messageID)
void	deliverAsync()
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()
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()
PageSubscription	getPageSubscription()
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(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	resume() Resumes the delivery of message for the queue.
int	sendMessagesToDeadLetterAddress(Filter filter)
boolean	sendMessageToDeadLetterAddress(long messageID)
void	setExpiryAddress(SimpleString expiryAddress)
void	setInternalQueue(boolean internalQueue)

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)
                    throws Exception

Throws:

Exception

getConsumerCount

int getConsumerCount()

reload

void reload(MessageReference ref)

addTail

void addTail(MessageReference ref)

addTail

void addTail(MessageReference ref,
           boolean direct)

addHead

void addHead(MessageReference ref)

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(MessageReference reference,
          long timeBase)
            throws Exception

Throws:

Exception

deliverAsync

void deliverAsync()

forceDelivery

void forceDelivery()

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

getMessageCount

long getMessageCount()

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

getMessagesAdded

long getMessagesAdded()

getInstantMessagesAdded

long getInstantMessagesAdded()

removeReferenceWithID

MessageReference removeReferenceWithID(long id)
                                       throws Exception

Throws:

Exception

getReference

MessageReference getReference(long id)

deleteAllReferences

int deleteAllReferences()
                        throws Exception

Throws:

Exception

deleteReference

boolean deleteReference(long messageID)
                        throws Exception

Throws:

Exception

deleteMatchingReferences

int deleteMatchingReferences(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(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)
                        throws Exception

Throws:

Exception

iterator

LinkedListIterator<MessageReference> iterator()

setExpiryAddress

void setExpiryAddress(SimpleString expiryAddress)

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)