Interface QueueControl
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
-
Method Summary
Modifier and TypeMethodDescriptionbrowse()
browse
(int page, int pageSize) boolean
changeMessagePriority
(long messageID, int newPriority) Changes the message's priority corresponding to the specified message ID to the specified priority.int
changeMessagesPriority
(String filter, int newPriority) Changes the priority for all the message corresponding to the specified filter to the specified priority.boolean
copyMessage
(long messageID, String targetQueue) long
countDeliveringMessages
(String filter) Counts the number of delivering messages in this queue matching the specified filter.countDeliveringMessages
(String filter, String groupByProperty) Counts the number of delivering messages in this queue matching the specified filter, grouped by the given property field.long
long
countMessages
(String filter) Counts the number of messages in this queue matching the specified filter.countMessages
(String filter, String groupByProperty) Counts the number of messages in this queue matching the specified filter, grouped by the given property field.void
deliverScheduledMessage
(long messageId) Deliver the scheduled message with the specified message IDvoid
deliverScheduledMessages
(String filter) Deliver the scheduled messages which match the filtervoid
disable()
Enables the queue.void
enable()
Enables the queue.boolean
expireMessage
(long messageID) Expires the message corresponding to the specified message ID.int
expireMessages
(String filter) Expires all the message corresponding to the specified filter.void
it will flush one cycle on internal executors, so you would be sure that any pending tasks are done before you call any other measure.long
Returns the number of messages added to this queue since it was created.Returns the address this queue is bound to.int
Returns the number of consumers consuming messages from this queue.int
Returns the Consumers Before Dispatch.Returns the dead-letter address associated with this queue.long
Returns the Delay Before Dispatch.int
Returns the number of messages that this queue is currently delivering to its consumers.long
Returns the persistent size of messages that this queue is currently delivering to its consumers.int
Returns the number of durable messages that this queue is currently delivering to its consumers.long
Returns the size of durable messages that this queue is currently delivering to its consumers.long
Returns the number of durable messages currently in this queue.long
Returns the persistent size of durable messages currently in this queue; the persistent size of a message is the amount of space the message would take up on disk which is used to track how much data there is to consume on this queue.long
Returns the number of durable scheduled messages in this queue.long
Returns the size of durable scheduled messages in this queue.Returns the expiry address associated with this queue.Returns the filter associated with this queue.Returns the age of the first message in milliseconds.Returns the first message on the queue as JSON.Returns the timestamp of the first message in milliseconds.int
Will return the group buckets.int
Will return the current number of active groups.Will return the header key to notify a consumer of a group change.long
getID()
Returns this queue ID.Returns key used for the last value queues.int
long
Returns the number of messages currently in this queue.long
Returns the number of messages added to this queue since it was created.long
Returns the number of messages added to this queue since it was created.long
Returns the number of messages expired from this queue since it was created.long
Returns the number of messages removed from this queue since it was created due to exceeding the max delivery attempts.getName()
Returns the name of this queue.long
Returns the persistent size of all messages currently in this queue; the persistent size of a message is the amount of space the message would take up on disk which is used to track how much data there is to consume on this queue.int
Will return the number of messages stuck in prepared transactionslong
Will return the ring size.The routing type of this queue.long
Returns the number of scheduled messages in this queue.long
Returns the size of scheduled messages in this queue.getUser()
Returns the user that is associated with creating the queue.boolean
Returns whether this queue is available for auto deletion.boolean
boolean
Returns whether this queue is durable.boolean
boolean
boolean
Returns whether the groups of this queue are automatically rebalanced.boolean
Returns whether the dispatch is paused when groups of this queue are automatically rebalanced.boolean
Returns whether this queue was created for the broker's internal use.boolean
boolean
isPaused()
Returns whether the queue is paused.boolean
Returns whether the queue's paused status is persisted.boolean
boolean
Returns whether this queue is used for a retroactive address.boolean
Returns whether this queue is temporary.Lists all the messages being deliver per consumer.Executes a conversion oflistDeliveringMessages()
to JSONLists the message counter for this queue.Lists the message counter for this queue as a HTML table.Lists the message counter history for this queue.Deprecated.listMessages
(String filter) Lists all the messages in this queue matching the specified filter.listMessagesAsJSON
(String filter) Lists all the messages in this queue matching the specified filter using JSON serialization.Lists all the messages scheduled for delivery for this queue.Lists all the messages scheduled for delivery for this queue using JSON serialization.boolean
moveMessage
(long messageID, String otherQueueName) Moves the message corresponding to the specified message ID to the specified other queue.boolean
moveMessage
(long messageID, String otherQueueName, boolean rejectDuplicates) Moves the message corresponding to the specified message ID to the specified other queue.int
moveMessages
(int flushLimit, String filter, String otherQueueName, boolean rejectDuplicates) int
moveMessages
(int flushLimit, String filter, String otherQueueName, boolean rejectDuplicates, int messageCount) int
moveMessages
(String filter, String otherQueueName) Moves all the message corresponding to the specified filter to the specified other queue.int
moveMessages
(String filter, String otherQueueName, boolean rejectDuplicates) Moves all the message corresponding to the specified filter to the specified other queue.void
pause()
Pauses the queue.void
pause
(boolean persist) Pauses the queue.Returns the first message on the queue as JSON.Returns the first scheduled message on the queue as JSON.int
Removes all the message from the queue.boolean
removeMessage
(long messageID) Removes the message corresponding to the specified message ID.int
removeMessages
(int flushLimit, String filter) Removes all the message corresponding to the specified filter.int
removeMessages
(String filter) Removes all the message corresponding to the specified filter.void
Will reset the all the groups.void
resetGroup
(String groupID) Will reset the group matching the given groupID.void
Resets the message counter for this queue.void
Resets the MessagesAdded propertyvoid
Resets the MessagesAdded propertyvoid
Resets the MessagesExpired propertyvoid
Resets the MessagesExpired propertyvoid
resume()
Resumes the queue.boolean
retryMessage
(long messageID) Retries the message corresponding to the given messageID to the original queue.int
Retries all messages on a DLQ to their respective original queues.sendMessage
(Map<String, String> headers, int type, String body, boolean durable, String user, String password) Sends a TextMessage to a password-protected destination.sendMessage
(Map<String, String> headers, int type, String body, boolean durable, String user, String password, boolean createMessageId) Sends a TextMessage to a password-protected destination.int
sendMessagesToDeadLetterAddress
(String filterStr) Sends all the message corresponding to the specified filter to this queue's dead letter address.boolean
sendMessageToDeadLetterAddress
(long messageID) Sends the message corresponding to the specified message ID to this queue's dead letter address.
-
Field Details
-
MESSAGE_COUNT_DESCRIPTION
- See Also:
-
DURABLE_MESSAGE_COUNT_DESCRIPTION
- See Also:
-
PERSISTENT_SIZE_DESCRIPTION
- See Also:
-
DURABLE_PERSISTENT_SIZE_DESCRIPTION
- See Also:
-
SCHEDULED_MESSAGE_COUNT_DESCRIPTION
- See Also:
-
DURABLE_SCHEDULED_MESSAGE_COUNT_DESCRIPTION
- See Also:
-
SCHEDULED_SIZE_DESCRIPTION
- See Also:
-
DURABLE_SCHEDULED_SIZE_DESCRIPTION
- See Also:
-
DELIVERING_MESSAGE_COUNT_DESCRIPTION
- See Also:
-
DURABLE_DELIVERING_MESSAGE_COUNT_DESCRIPTION
- See Also:
-
DELIVERING_SIZE_DESCRIPTION
- See Also:
-
DURABLE_DELIVERING_SIZE_DESCRIPTION
- See Also:
-
CONSUMER_COUNT_DESCRIPTION
- See Also:
-
MESSAGES_ADDED_DESCRIPTION
- See Also:
-
MESSAGES_ACKNOWLEDGED_DESCRIPTION
- See Also:
-
MESSAGES_EXPIRED_DESCRIPTION
- See Also:
-
MESSAGES_KILLED_DESCRIPTION
- See Also:
-
-
Method Details
-
getName
String getName()Returns the name of this queue.- Returns:
- the name of this queue
-
getAddress
String getAddress()Returns the address this queue is bound to.- Returns:
- the address this queue is bound to
-
getID
long getID()Returns this queue ID.- Returns:
- this queue ID
-
isTemporary
boolean isTemporary()Returns whether this queue is temporary.- Returns:
- whether this queue is temporary
-
isRetroactiveResource
boolean isRetroactiveResource()Returns whether this queue is used for a retroactive address.- Returns:
- whether this queue is used for a retroactive address
-
isDurable
boolean isDurable()Returns whether this queue is durable.- Returns:
- whether this queue is durable
-
getUser
String getUser()Returns the user that is associated with creating the queue.- Returns:
- the user that is associated with creating the queue
-
getRoutingType
String getRoutingType()The routing type of this queue. -
getFilter
String getFilter()Returns the filter associated with this queue.- Returns:
- the filter associated with this queue
-
getMessageCount
long getMessageCount()Returns the number of messages currently in this queue.- Returns:
- the number of messages currently in this queue
-
getPersistentSize
long getPersistentSize()Returns the persistent size of all messages currently in this queue; the persistent size of a message is the amount of space the message would take up on disk which is used to track how much data there is to consume on this queue.- Returns:
- the persistent size of all messages currently in this queue; the persistent size of a message is the amount of space the message would take up on disk which is used to track how much data there is to consume on this queue
-
getDurableMessageCount
long getDurableMessageCount()Returns the number of durable messages currently in this queue.- Returns:
- the number of durable messages currently in this queue
-
getDurablePersistentSize
long getDurablePersistentSize()Returns the persistent size of durable messages currently in this queue; the persistent size of a message is the amount of space the message would take up on disk which is used to track how much data there is to consume on this queue.- Returns:
- the persistent size of durable messages currently in this queue; the persistent size of a message is the amount of space the message would take up on disk which is used to track how much data there is to consume on this queue
-
isInternalQueue
boolean isInternalQueue()Returns whether this queue was created for the broker's internal use.- Returns:
- whether this queue was created for the broker's internal use
-
getScheduledCount
long getScheduledCount()Returns the number of scheduled messages in this queue.- Returns:
- the number of scheduled messages in this queue
-
getScheduledSize
long getScheduledSize()Returns the size of scheduled messages in this queue.- Returns:
- the size of scheduled messages in this queue
-
getDurableScheduledCount
long getDurableScheduledCount()Returns the number of durable scheduled messages in this queue.- Returns:
- the number of durable scheduled messages in this queue
-
getDurableScheduledSize
long getDurableScheduledSize()Returns the size of durable scheduled messages in this queue.- Returns:
- the size of durable scheduled messages in this queue
-
getConsumerCount
int getConsumerCount()Returns the number of consumers consuming messages from this queue.- Returns:
- the number of consumers consuming messages from this queue
-
getDeliveringCount
int getDeliveringCount()Returns the number of messages that this queue is currently delivering to its consumers.- Returns:
- the number of messages that this queue is currently delivering to its consumers
-
getDeliveringSize
long getDeliveringSize()Returns the persistent size of messages that this queue is currently delivering to its consumers.- Returns:
- the persistent size of messages that this queue is currently delivering to its consumers
-
getDurableDeliveringCount
int getDurableDeliveringCount()Returns the number of durable messages that this queue is currently delivering to its consumers.- Returns:
- the number of durable messages that this queue is currently delivering to its consumers
-
getDurableDeliveringSize
long getDurableDeliveringSize()Returns the size of durable messages that this queue is currently delivering to its consumers.- Returns:
- the size of durable messages that this queue is currently delivering to its consumers
-
getMessagesAdded
long getMessagesAdded()Returns the number of messages added to this queue since it was created.- Returns:
- the number of messages added to this queue since it was created
-
getMessagesAcknowledged
long getMessagesAcknowledged()Returns the number of messages added to this queue since it was created.- Returns:
- the number of messages added to this queue since it was created
-
getAcknowledgeAttempts
long getAcknowledgeAttempts()Returns the number of messages added to this queue since it was created.- Returns:
- the number of messages added to this queue since it was created
-
getMessagesExpired
long getMessagesExpired()Returns the number of messages expired from this queue since it was created.- Returns:
- the number of messages expired from this queue since it was created
-
getMessagesKilled
long getMessagesKilled()Returns the number of messages removed from this queue since it was created due to exceeding the max delivery attempts.- Returns:
- the number of messages removed from this queue since it was created due to exceeding the max delivery attempts
-
getFirstMessageAsJSON
Returns the first message on the queue as JSON.- Returns:
- the first message on the queue as JSON
- Throws:
Exception
-
getFirstMessageTimestamp
Returns the timestamp of the first message in milliseconds.- Returns:
- the timestamp of the first message in milliseconds
- Throws:
Exception
-
getFirstMessageAge
Returns the age of the first message in milliseconds.- Returns:
- the age of the first message in milliseconds
- Throws:
Exception
-
getExpiryAddress
String getExpiryAddress()Returns the expiry address associated with this queue.- Returns:
- the expiry address associated with this queue
-
getDeadLetterAddress
String getDeadLetterAddress()Returns the dead-letter address associated with this queue.- Returns:
- the dead-letter address associated with this queue
-
getMaxConsumers
int getMaxConsumers() -
isPurgeOnNoConsumers
boolean isPurgeOnNoConsumers() -
isEnabled
boolean isEnabled() -
enable
Enables the queue. Messages are now routed to this queue.- Throws:
Exception
-
disable
Enables the queue. Messages are not routed to this queue.- Throws:
Exception
-
isConfigurationManaged
boolean isConfigurationManaged() -
isExclusive
boolean isExclusive() -
isLastValue
boolean isLastValue() -
getLastValueKey
String getLastValueKey()Returns key used for the last value queues.- Returns:
- key used for the last value queues
-
getConsumersBeforeDispatch
int getConsumersBeforeDispatch()Returns the Consumers Before Dispatch.- Returns:
- the Consumers Before Dispatch
-
getDelayBeforeDispatch
long getDelayBeforeDispatch()Returns the Delay Before Dispatch.- Returns:
- the Delay Before Dispatch
-
listScheduledMessages
Lists all the messages scheduled for delivery for this queue.1 Map represents 1 message, keys are the message's properties and headers, values are the corresponding values.
- Throws:
Exception
-
listScheduledMessagesAsJSON
Lists all the messages scheduled for delivery for this queue using JSON serialization.- Throws:
Exception
-
listDeliveringMessages
Lists all the messages being deliver per consumer.The Map's key is a toString representation for the consumer. Each consumer will then return a
Map<String,Object>[]
same way is returned bylistScheduledMessages()
- Throws:
Exception
-
listDeliveringMessagesAsJSON
Executes a conversion oflistDeliveringMessages()
to JSON- Throws:
Exception
-
listMessages
Lists all the messages in this queue matching the specified filter.1 Map represents 1 message, keys are the message's properties and headers, values are the corresponding values.
Using
null
or an empty filter will list all messages from this queue.- Throws:
Exception
-
listMessagesAsJSON
Lists all the messages in this queue matching the specified filter using JSON serialization.Using
null
or an empty filter will list all messages from this queue.- Throws:
Exception
-
countMessages
Counts the number of messages in this queue matching the specified filter.Using
null
or an empty filter will count all messages from this queue.- Throws:
Exception
-
countMessages
- Throws:
Exception
-
countMessages
Counts the number of messages in this queue matching the specified filter, grouped by the given property field. In case of null property will be grouped in "null"Using
null
or an empty filter will count all messages from this queue.- Throws:
Exception
-
countDeliveringMessages
Counts the number of delivering messages in this queue matching the specified filter.Using
null
or an empty filter will count all messages from this queue.- Throws:
Exception
-
countDeliveringMessages
Counts the number of delivering messages in this queue matching the specified filter, grouped by the given property field. In case of null property will be grouped in "null"Using
null
or an empty filter will count all messages from this queue.- Throws:
Exception
-
removeMessage
Removes the message corresponding to the specified message ID.- Returns:
true
if the message was removed,false
else- Throws:
Exception
-
removeMessages
Removes all the message corresponding to the specified filter.Using
null
or an empty filter will remove all messages from this queue.- Returns:
- the number of removed messages
- Throws:
Exception
-
removeMessages
Removes all the message corresponding to the specified filter.Using
null
or an empty filter will remove all messages from this queue.- Returns:
- the number of removed messages
- Throws:
Exception
-
removeAllMessages
Removes all the message from the queue.- Returns:
- the number of removed messages
- Throws:
Exception
-
expireMessages
Expires all the message corresponding to the specified filter.Using
null
or an empty filter will expire all messages from this queue.- Returns:
- the number of expired messages
- Throws:
Exception
-
expireMessage
Expires the message corresponding to the specified message ID.- Returns:
true
if the message was expired,false
else- Throws:
Exception
-
retryMessage
Retries the message corresponding to the given messageID to the original queue. This is appropriate on dead messages on Dead letter queues only.- Returns:
true
if the message was retried,false
else- Throws:
Exception
-
retryMessages
Retries all messages on a DLQ to their respective original queues. This is appropriate on dead messages on Dead letter queues only.- Returns:
- the number of retried messages
- Throws:
Exception
-
moveMessage
Moves the message corresponding to the specified message ID to the specified other queue.- Returns:
true
if the message was moved,false
else- Throws:
Exception
-
moveMessage
boolean moveMessage(long messageID, String otherQueueName, boolean rejectDuplicates) throws Exception Moves the message corresponding to the specified message ID to the specified other queue.- Returns:
true
if the message was moved,false
else- Throws:
Exception
-
moveMessages
Moves all the message corresponding to the specified filter to the specified other queue. RejectDuplicates = false on this caseUsing
null
or an empty filter will move all messages from this queue.- Returns:
- the number of moved messages
- Throws:
Exception
-
moveMessages
Moves all the message corresponding to the specified filter to the specified other queue.Using
null
or an empty filter will move all messages from this queue.- Returns:
- the number of moved messages
- Throws:
Exception
-
moveMessages
int moveMessages(int flushLimit, String filter, String otherQueueName, boolean rejectDuplicates) throws Exception - Throws:
Exception
-
moveMessages
int moveMessages(int flushLimit, String filter, String otherQueueName, boolean rejectDuplicates, int messageCount) throws Exception - Throws:
Exception
-
copyMessage
- Throws:
Exception
-
sendMessageToDeadLetterAddress
Sends the message corresponding to the specified message ID to this queue's dead letter address.- Returns:
true
if the message was sent to the dead letter address,false
else- Throws:
Exception
-
sendMessagesToDeadLetterAddress
Sends all the message corresponding to the specified filter to this queue's dead letter address.Using
null
or an empty filter will send all messages from this queue.- Returns:
- the number of sent messages
- Throws:
Exception
-
sendMessage
String sendMessage(Map<String, String> headers, int type, String body, boolean durable, String user, String password) throws ExceptionSends a TextMessage to a password-protected destination.- Parameters:
headers
- the message headers and properties to set. Can only container Strings maped to primitive types.body
- the text to send- Throws:
Exception
-
sendMessage
String sendMessage(Map<String, String> headers, int type, String body, boolean durable, String user, String password, boolean createMessageId) throws ExceptionSends a TextMessage to a password-protected destination.- Parameters:
headers
- the message headers and properties to set. Can only container Strings maped to primitive types.body
- the text to sendcreateMessageId
- whether to auto generate a Message ID- Throws:
Exception
-
changeMessagePriority
Changes the message's priority corresponding to the specified message ID to the specified priority.- Parameters:
newPriority
- between 0 and 9 inclusive.- Returns:
true
if the message priority was changed- Throws:
Exception
-
changeMessagesPriority
Changes the priority for all the message corresponding to the specified filter to the specified priority.Using
null
or an empty filter will change all messages from this queue.- Returns:
- the number of changed messages
- Throws:
Exception
-
listMessageCounter
Lists the message counter for this queue.- Throws:
Exception
-
resetMessageCounter
Resets the message counter for this queue.- Throws:
Exception
-
listMessageCounterAsHTML
Lists the message counter for this queue as a HTML table.- Throws:
Exception
-
listMessageCounterHistory
Lists the message counter history for this queue.- Throws:
Exception
-
listMessageCounterHistoryAsHTML
Deprecated.Lists the message counter history for this queue as a HTML table.- Throws:
Exception
-
pause
Pauses the queue. Messages are no longer delivered to its consumers.- Throws:
Exception
-
pause
Pauses the queue. Messages are no longer delivered to its consumers.- Throws:
Exception
-
resume
Resumes the queue. Messages are again delivered to its consumers.- Throws:
Exception
-
listConsumersAsJSON
- Throws:
Exception
-
isPaused
boolean isPaused()Returns whether the queue is paused.- Returns:
- whether the queue is paused
-
isPersistedPause
boolean isPersistedPause()Returns whether the queue's paused status is persisted.- Returns:
- whether the queue's paused status is persisted
-
browse
- Throws:
Exception
-
browse
- Throws:
Exception
-
browse
- Throws:
Exception
-
browse
- Throws:
Exception
-
resetMessagesAdded
Resets the MessagesAdded property- Throws:
Exception
-
resetMessagesAcknowledged
Resets the MessagesAdded property- Throws:
Exception
-
resetMessagesExpired
Resets the MessagesExpired property- Throws:
Exception
-
resetMessagesKilled
Resets the MessagesExpired property- Throws:
Exception
-
flushExecutor
void flushExecutor()it will flush one cycle on internal executors, so you would be sure that any pending tasks are done before you call any other measure. It is useful if you need the exact number of counts on a message -
resetAllGroups
void resetAllGroups()Will reset the all the groups. This is useful if you want a complete rebalance of the groups to consumers -
resetGroup
Will reset the group matching the given groupID. This is useful if you want the given group to be rebalanced to the consumers -
getGroupCount
int getGroupCount()Will return the current number of active groups. -
listGroupsAsJSON
- Throws:
Exception
-
getRingSize
long getRingSize()Will return the ring size. -
isGroupRebalance
boolean isGroupRebalance()Returns whether the groups of this queue are automatically rebalanced.- Returns:
- whether the groups of this queue are automatically rebalanced
-
isGroupRebalancePauseDispatch
boolean isGroupRebalancePauseDispatch()Returns whether the dispatch is paused when groups of this queue are automatically rebalanced.- Returns:
- whether the dispatch is paused when groups of this queue are automatically rebalanced
-
getGroupBuckets
int getGroupBuckets()Will return the group buckets. -
getGroupFirstKey
String getGroupFirstKey()Will return the header key to notify a consumer of a group change. -
getPreparedTransactionMessageCount
int getPreparedTransactionMessageCount()Will return the number of messages stuck in prepared transactions -
deliverScheduledMessages
Deliver the scheduled messages which match the filter- Throws:
Exception
-
deliverScheduledMessage
Deliver the scheduled message with the specified message ID- Throws:
Exception
-
isAutoDelete
boolean isAutoDelete()Returns whether this queue is available for auto deletion.- Returns:
- whether this queue is available for auto deletion
-
peekFirstMessageAsJSON
Returns the first message on the queue as JSON.- Returns:
- the first message on the queue as JSON
- Throws:
Exception
-
peekFirstScheduledMessageAsJSON
Returns the first scheduled message on the queue as JSON.- Returns:
- the first scheduled message on the queue as JSON
- Throws:
Exception
-