public interface JMSQueueControl extends DestinationControl
Modifier and Type | Method and Description |
---|---|
void |
addJNDI(java.lang.String jndi)
Add the JNDI binding to this destination
|
boolean |
changeMessagePriority(java.lang.String messageID,
int newPriority)
Changes the message's priority corresponding to the specified message ID to the specified priority.
|
int |
changeMessagesPriority(java.lang.String filter,
int newPriority)
Changes the priority for all the message corresponding to the specified filter to the specified priority.
|
long |
countMessages(java.lang.String filter)
Counts the number of messages in this queue matching the specified filter.
|
boolean |
expireMessage(java.lang.String messageID)
Expires the message corresponding to the specified message ID.
|
int |
expireMessages(java.lang.String filter)
Expires all the message corresponding to the specified filter.
|
int |
getConsumerCount()
Returns the number of consumers consuming messages from this queue.
|
java.lang.String |
getDeadLetterAddress()
Returns the dead-letter address associated to this queue.
|
java.lang.String |
getExpiryAddress()
Returns the expiry address associated to this queue.
|
java.lang.String[] |
getJNDIBindings()
Returns the JNDI bindings associated to this connection factory.
|
long |
getScheduledCount()
Returns the number of scheduled messages in this queue.
|
java.lang.String |
getSelector()
returns the selector for the queue
|
boolean |
isPaused()
Returns whether the queue is paused.
|
java.lang.String |
listConsumersAsJSON() |
java.lang.String |
listMessageCounter()
Lists the message counter for this queue.
|
java.lang.String |
listMessageCounterAsHTML()
Lists the message counter for this queue as a HTML table.
|
java.lang.String |
listMessageCounterHistory()
Lists the message counter history for this queue.
|
java.lang.String |
listMessageCounterHistoryAsHTML()
Lists the message counter history for this queue as a HTML table.
|
java.util.Map<java.lang.String,java.lang.Object>[] |
listMessages(java.lang.String filter)
Lists all the JMS messages in this queue matching the specified filter.
|
java.lang.String |
listMessagesAsJSON(java.lang.String filter)
Lists all the JMS messages in this queue matching the specified filter using JSON serialization.
|
boolean |
moveMessage(java.lang.String messageID,
java.lang.String otherQueueName)
Moves the message corresponding to the specified message ID to the specified other queue.
|
boolean |
moveMessage(java.lang.String messageID,
java.lang.String otherQueueName,
boolean rejectDuplicates)
Moves the message corresponding to the specified message ID to the specified other queue.
|
int |
moveMessages(java.lang.String filter,
java.lang.String otherQueueName)
Moves all the message corresponding to the specified filter to the specified other queue.
|
int |
moveMessages(java.lang.String filter,
java.lang.String otherQueueName,
boolean rejectDuplicates)
Moves all the message corresponding to the specified filter to the specified other queue.
|
void |
pause()
Pauses the queue.
|
void |
removeJNDI(java.lang.String jndi) |
boolean |
removeMessage(java.lang.String messageID)
Removes the message corresponding to the specified message ID.
|
int |
removeMessages(java.lang.String filter)
Removes all the message corresponding to the specified filter.
|
void |
resetMessageCounter()
Resets the message counter for this queue.
|
void |
resume()
Resumes the queue.
|
int |
sendMessagesToDeadLetterAddress(java.lang.String filterStr)
Sends all the message corresponding to the specified filter to this queue's dead letter address.
|
boolean |
sendMessageToDeadLetterAddress(java.lang.String messageID)
Sends the message corresponding to the specified message ID to this queue's dead letter address.
|
void |
setDeadLetterAddress(java.lang.String deadLetterAddress)
Sets the dead-letter address associated to this queue to the specified deadLetterAddress.
|
void |
setExpiryAddress(java.lang.String expiryAddress)
Sets the expiry address associated to this queue to the specified expiryAddress.
|
getAddress, getDeliveringCount, getMessageCount, getMessagesAdded, getName, isTemporary
java.lang.String getExpiryAddress()
void setExpiryAddress(java.lang.String expiryAddress) throws java.lang.Exception
java.lang.Exception
java.lang.String getDeadLetterAddress()
void setDeadLetterAddress(java.lang.String deadLetterAddress) throws java.lang.Exception
java.lang.Exception
long getScheduledCount()
int getConsumerCount()
java.lang.String getSelector()
java.lang.String[] getJNDIBindings()
void addJNDI(java.lang.String jndi) throws java.lang.Exception
java.lang.Exception
void removeJNDI(java.lang.String jndi) throws java.lang.Exception
java.lang.Exception
java.util.Map<java.lang.String,java.lang.Object>[] listMessages(java.lang.String filter) throws java.lang.Exception
null
or an empty filter will list all messages from this queue.java.lang.Exception
java.lang.String listMessagesAsJSON(java.lang.String filter) throws java.lang.Exception
null
or an empty filter will list all messages from this queue.java.lang.Exception
long countMessages(java.lang.String filter) throws java.lang.Exception
null
or an empty filter will count all messages from this queue.java.lang.Exception
boolean removeMessage(java.lang.String messageID) throws java.lang.Exception
true
if the message was removed, false
elsejava.lang.Exception
int removeMessages(java.lang.String filter) throws java.lang.Exception
null
or an empty filter will remove all messages from this queue.removeMessages
in interface DestinationControl
java.lang.Exception
int expireMessages(java.lang.String filter) throws java.lang.Exception
null
or an empty filter will expire all messages from this queue.java.lang.Exception
boolean expireMessage(java.lang.String messageID) throws java.lang.Exception
true
if the message was expired, false
elsejava.lang.Exception
boolean sendMessageToDeadLetterAddress(java.lang.String messageID) throws java.lang.Exception
true
if the message was sent to the dead letter address, false
elsejava.lang.Exception
int sendMessagesToDeadLetterAddress(java.lang.String filterStr) throws java.lang.Exception
null
or an empty filter will send all messages from this queue.java.lang.Exception
boolean changeMessagePriority(java.lang.String messageID, int newPriority) throws java.lang.Exception
newPriority
- between 0 and 9 inclusive.true
if the message priority was changedjava.lang.Exception
int changeMessagesPriority(java.lang.String filter, int newPriority) throws java.lang.Exception
null
or an empty filter will change all messages from this queue.java.lang.Exception
boolean moveMessage(java.lang.String messageID, java.lang.String otherQueueName) throws java.lang.Exception
true
if the message was moved, false
elsejava.lang.Exception
boolean moveMessage(java.lang.String messageID, java.lang.String otherQueueName, boolean rejectDuplicates) throws java.lang.Exception
true
if the message was moved, false
elsejava.lang.Exception
int moveMessages(java.lang.String filter, java.lang.String otherQueueName) throws java.lang.Exception
null
or an empty filter will move all messages from this queue.java.lang.Exception
int moveMessages(java.lang.String filter, java.lang.String otherQueueName, boolean rejectDuplicates) throws java.lang.Exception
null
or an empty filter will move all messages from this queue.java.lang.Exception
java.lang.String listMessageCounter() throws java.lang.Exception
java.lang.Exception
void resetMessageCounter() throws java.lang.Exception
java.lang.Exception
java.lang.String listMessageCounterAsHTML() throws java.lang.Exception
java.lang.Exception
java.lang.String listMessageCounterHistory() throws java.lang.Exception
java.lang.Exception
java.lang.String listMessageCounterHistoryAsHTML() throws java.lang.Exception
java.lang.Exception
void pause() throws java.lang.Exception
java.lang.Exception
boolean isPaused() throws java.lang.Exception
java.lang.Exception
void resume() throws java.lang.Exception
java.lang.Exception
java.lang.String listConsumersAsJSON() throws java.lang.Exception
java.lang.Exception
Copyright © 2009 Red Hat Inc. All Rights Reserved.