public interface Queue extends Bindable
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) |
SimpleString getName()
long getID()
Filter getFilter()
PageSubscription getPageSubscription()
boolean isDurable()
boolean isTemporary()
void removeConsumer(Consumer consumer)
int getConsumerCount()
void setConsumersRefCount(HornetQServer server)
ReferenceCounter getConsumersRefCount()
void reload(MessageReference ref)
void addTail(MessageReference ref)
void addTail(MessageReference ref, boolean direct)
void addHead(MessageReference ref)
void addHead(List<MessageReference> refs)
void acknowledge(MessageReference ref) throws Exception
Exception
void acknowledge(Transaction tx, MessageReference ref) throws Exception
Exception
void reacknowledge(Transaction tx, MessageReference ref) throws Exception
Exception
void cancel(Transaction tx, MessageReference ref)
void cancel(Transaction tx, MessageReference ref, boolean ignoreRedeliveryCheck)
void cancel(MessageReference reference, long timeBase) throws Exception
Exception
void deliverAsync()
void unproposed(SimpleString groupID)
void forceDelivery()
long getMessageCount()
long getMessageCount(long timeout)
timeout
- Time to wait for current executors to finish in milliseconds.long getInstantMessageCount()
int getDeliveringCount()
void referenceHandled()
int getScheduledCount()
List<MessageReference> getScheduledMessages()
Map<String,List<MessageReference>> getDeliveringMessages()
long getMessagesAdded()
long getMessagesAdded(long timeout)
timeout
- Time to wait for current executors to finish in milliseconds.long getInstantMessagesAdded()
MessageReference removeReferenceWithID(long id) throws Exception
Exception
MessageReference getReference(long id)
int deleteMatchingReferences(Filter filter) throws Exception
Exception
int deleteMatchingReferences(int flushLImit, Filter filter) throws Exception
Exception
int expireReferences(Filter filter) throws Exception
Exception
void expire(MessageReference ref) throws Exception
Exception
boolean sendMessageToDeadLetterAddress(long messageID) throws Exception
Exception
int sendMessagesToDeadLetterAddress(Filter filter) throws Exception
Exception
boolean changeReferencePriority(long messageID, byte newPriority) throws Exception
Exception
int changeReferencesPriority(Filter filter, byte newPriority) throws Exception
Exception
boolean moveReference(long messageID, SimpleString toAddress) throws Exception
Exception
boolean moveReference(long messageID, SimpleString toAddress, boolean rejectDuplicates) throws Exception
Exception
int moveReferences(Filter filter, SimpleString toAddress) throws Exception
Exception
int moveReferences(int flushLimit, Filter filter, SimpleString toAddress, boolean rejectDuplicates) throws Exception
Exception
void addRedistributor(long delay)
boolean hasMatchingConsumer(ServerMessage message)
Collection<Consumer> getConsumers()
boolean checkRedelivery(MessageReference ref, long timeBase, boolean ignoreRedeliveryDelay) throws Exception
Exception
LinkedListIterator<MessageReference> iterator()
LinkedListIterator<MessageReference> totalIterator()
SimpleString getExpiryAddress()
void pause()
void resume()
boolean isPaused()
Executor getExecutor()
void resetAllIterators()
boolean flushExecutor()
boolean isDirectDeliver()
SimpleString getAddress()
boolean isInternalQueue()
void setInternalQueue(boolean internalQueue)
void resetMessagesAdded()
float getRate()
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.