public interface Queue extends Bindable, CriticalComponent
Modifier and Type | Field and Description |
---|---|
static int |
MAX_CONSUMERS_UNLIMITED |
Modifier and Type | Method and Description |
---|---|
void |
acknowledge(MessageReference ref) |
void |
acknowledge(MessageReference ref,
AckReason reason,
ServerConsumer consumer) |
void |
acknowledge(MessageReference ref,
ServerConsumer consumer) |
void |
acknowledge(Transaction tx,
MessageReference ref) |
void |
acknowledge(Transaction tx,
MessageReference ref,
AckReason reason,
ServerConsumer consumer) |
void |
addConsumer(Consumer consumer) |
void |
addHead(List<MessageReference> refs,
boolean scheduling) |
void |
addHead(MessageReference ref,
boolean scheduling) |
void |
addRedistributor(long delay) |
void |
addTail(MessageReference ref) |
void |
addTail(MessageReference ref,
boolean direct) |
LinkedListIterator<MessageReference> |
browserIterator() |
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) |
default int |
deleteMatchingReferences(int flushLImit,
Filter filter) |
int |
deleteMatchingReferences(int flushLImit,
Filter filter,
AckReason ackReason) |
void |
deleteQueue() |
void |
deleteQueue(boolean removeConsumers) |
boolean |
deleteReference(long messageID) |
void |
deliverAsync() |
void |
deliverScheduledMessages()
cancels scheduled messages and send them to the head of the queue.
|
void |
destroyPaging() |
void |
expire(MessageReference ref) |
void |
expire(MessageReference ref,
ServerConsumer consumer) |
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
|
long |
getDeliveringSize() |
int |
getDurableDeliveringCount() |
long |
getDurableDeliveringSize() |
long |
getDurableMessageCount()
This is the number of the durable messages in the queue
|
long |
getDurablePersistentSize()
This is the persistent size of all the durable messages in the queue
|
int |
getDurableScheduledCount() |
long |
getDurableScheduledSize() |
Executor |
getExecutor() |
SimpleString |
getExpiryAddress() |
Filter |
getFilter() |
int |
getGroupCount() |
Map<SimpleString,Consumer> |
getGroups() |
long |
getID() |
int |
getMaxConsumers() |
long |
getMessageCount() |
long |
getMessagesAcknowledged() |
long |
getMessagesAdded() |
long |
getMessagesExpired() |
long |
getMessagesKilled() |
SimpleString |
getName() |
PageSubscription |
getPageSubscription() |
long |
getPersistentSize()
This is the size of the messages in the queue when persisted on disk which is used for metrics tracking
to give an idea of the amount of data on the queue to be consumed
Note that this includes all messages on the queue, even messages that are non-durable which may only be in memory
|
float |
getRate() |
MessageReference |
getReference(long id) |
RoutingType |
getRoutingType() |
int |
getScheduledCount() |
List<MessageReference> |
getScheduledMessages() |
long |
getScheduledSize() |
SimpleString |
getUser() |
boolean |
hasMatchingConsumer(Message message) |
void |
incrementMesssagesAdded() |
boolean |
isAutoCreated() |
boolean |
isDirectDeliver() |
boolean |
isDurable() |
boolean |
isDurableMessage()
The queue definition could be durable, but the messages could eventually be considered non durable.
|
boolean |
isExclusive() |
boolean |
isInternalQueue()
We can't send stuff to DLQ on queues used on clustered-bridge-communication
|
boolean |
isLastValue() |
boolean |
isPaused() |
boolean |
isPersistedPause()
if the pause was persisted
|
boolean |
isPurgeOnNoConsumers() |
boolean |
isTemporary() |
LinkedListIterator<MessageReference> |
iterator()
It will iterate thorugh memory only (not paging)
|
boolean |
moveReference(long messageID,
SimpleString toAddress,
Binding binding,
boolean rejectDuplicates) |
int |
moveReferences(Filter filter,
SimpleString toAddress,
Binding binding) |
int |
moveReferences(int flushLimit,
Filter filter,
SimpleString toAddress,
boolean rejectDuplicates,
Binding binding) |
void |
pause()
Pauses the queue.
|
void |
pause(boolean persist)
Pauses the queue.
|
void |
postAcknowledge(MessageReference ref) |
void |
reacknowledge(Transaction tx,
MessageReference ref) |
void |
recheckRefCount(OperationContext context)
This is to perform a check on the counter again
|
void |
referenceHandled(MessageReference ref) |
void |
reload(MessageReference ref) |
void |
reloadPause(long recordID) |
void |
removeConsumer(Consumer consumer) |
MessageReference |
removeReferenceWithID(long id) |
void |
resetAllGroups() |
void |
resetAllIterators() |
void |
resetGroup(SimpleString groupID) |
void |
resetMessagesAcknowledged() |
void |
resetMessagesAdded() |
void |
resetMessagesExpired() |
void |
resetMessagesKilled() |
void |
resume()
Resumes the delivery of message for the queue.
|
int |
retryMessages(Filter filter) |
int |
sendMessagesToDeadLetterAddress(Filter filter) |
boolean |
sendMessageToDeadLetterAddress(long messageID) |
void |
sendToDeadLetterAddress(Transaction tx,
MessageReference ref) |
void |
setConsumersRefCount(ReferenceCounter referenceCounter)
This will set a reference counter for every consumer present on the queue.
|
void |
setExclusive(boolean value) |
void |
setInternalQueue(boolean internalQueue) |
void |
setMaxConsumer(int maxConsumers) |
void |
setPurgeOnNoConsumers(boolean value) |
void |
setRoutingType(RoutingType routingType) |
void |
unproposed(SimpleString groupID) |
route, routeWithAck
enterCritical, isExpired, leaveCritical
static final int MAX_CONSUMERS_UNLIMITED
SimpleString getName()
long getID()
Filter getFilter()
PageSubscription getPageSubscription()
RoutingType getRoutingType()
void setRoutingType(RoutingType routingType)
boolean isDurable()
boolean isDurableMessage()
boolean isTemporary()
boolean isAutoCreated()
boolean isPurgeOnNoConsumers()
void setPurgeOnNoConsumers(boolean value)
boolean isExclusive()
void setExclusive(boolean value)
boolean isLastValue()
int getMaxConsumers()
void setMaxConsumer(int maxConsumers)
void removeConsumer(Consumer consumer)
int getConsumerCount()
void setConsumersRefCount(ReferenceCounter referenceCounter)
ReferenceCounter getConsumersRefCount()
void reload(MessageReference ref)
void addTail(MessageReference ref)
void addTail(MessageReference ref, boolean direct)
void addHead(MessageReference ref, boolean scheduling)
void addHead(List<MessageReference> refs, boolean scheduling)
void acknowledge(MessageReference ref) throws Exception
Exception
void acknowledge(MessageReference ref, ServerConsumer consumer) throws Exception
Exception
void acknowledge(MessageReference ref, AckReason reason, ServerConsumer consumer) throws Exception
Exception
void acknowledge(Transaction tx, MessageReference ref) throws Exception
Exception
void acknowledge(Transaction tx, MessageReference ref, AckReason reason, ServerConsumer consumer) 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 getPersistentSize()
long getDurableMessageCount()
long getDurablePersistentSize()
int getDeliveringCount()
long getDeliveringSize()
int getDurableDeliveringCount()
long getDurableDeliveringSize()
void referenceHandled(MessageReference ref)
int getScheduledCount()
long getScheduledSize()
int getDurableScheduledCount()
long getDurableScheduledSize()
List<MessageReference> getScheduledMessages()
Map<String,List<MessageReference>> getDeliveringMessages()
long getMessagesAdded()
long getMessagesAcknowledged()
long getMessagesExpired()
long getMessagesKilled()
MessageReference removeReferenceWithID(long id) throws Exception
Exception
MessageReference getReference(long id) throws ActiveMQException
ActiveMQException
int deleteMatchingReferences(Filter filter) throws Exception
Exception
default int deleteMatchingReferences(int flushLImit, Filter filter) throws Exception
Exception
int deleteMatchingReferences(int flushLImit, Filter filter, AckReason ackReason) throws Exception
Exception
int expireReferences(Filter filter) throws Exception
Exception
void expire(MessageReference ref) throws Exception
Exception
void expire(MessageReference ref, ServerConsumer consumer) throws Exception
Exception
boolean sendMessageToDeadLetterAddress(long messageID) throws Exception
Exception
int sendMessagesToDeadLetterAddress(Filter filter) throws Exception
Exception
void sendToDeadLetterAddress(Transaction tx, MessageReference ref) 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, Binding binding, boolean rejectDuplicates) throws Exception
Exception
int moveReferences(Filter filter, SimpleString toAddress, Binding binding) throws Exception
Exception
int moveReferences(int flushLimit, Filter filter, SimpleString toAddress, boolean rejectDuplicates, Binding binding) throws Exception
Exception
void addRedistributor(long delay)
boolean hasMatchingConsumer(Message message)
Collection<Consumer> getConsumers()
Map<SimpleString,Consumer> getGroups()
void resetGroup(SimpleString groupID)
void resetAllGroups()
int getGroupCount()
boolean checkRedelivery(MessageReference ref, long timeBase, boolean ignoreRedeliveryDelay) throws Exception
Exception
LinkedListIterator<MessageReference> iterator()
LinkedListIterator<MessageReference> browserIterator()
SimpleString getExpiryAddress()
void pause()
void pause(boolean persist)
void reloadPause(long recordID)
void resume()
boolean isPaused()
boolean isPersistedPause()
Executor getExecutor()
void resetAllIterators()
boolean flushExecutor()
boolean isDirectDeliver()
SimpleString getAddress()
boolean isInternalQueue()
void setInternalQueue(boolean internalQueue)
void resetMessagesAdded()
void resetMessagesAcknowledged()
void resetMessagesExpired()
void resetMessagesKilled()
void incrementMesssagesAdded()
void deliverScheduledMessages() throws ActiveMQException
ActiveMQException
void postAcknowledge(MessageReference ref)
float getRate()
SimpleString getUser()
void recheckRefCount(OperationContext context)
Copyright © 2019 JBoss by Red Hat. All rights reserved.