org.hornetq.api.jms.management

Interface JMSQueueControl

All Superinterfaces:

DestinationControl

All Known Implementing Classes:

JMSQueueControlImpl

public interface JMSQueueControl
extends DestinationControl

A JMSQueueControl is used to manage a JMS queue.

Author:

Jeff Mesnil

Method Summary

Methods

Modifier and Type	Method and Description
void	addJNDI(String jndi) Add the JNDI binding to this destination
boolean	changeMessagePriority(String 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.
long	countMessages(String filter) Counts the number of messages in this queue matching the specified filter.
boolean	expireMessage(String messageID) Expires the message corresponding to the specified message ID.
int	expireMessages(String filter) Expires all the message corresponding to the specified filter.
int	getConsumerCount() Returns the number of consumers consuming messages from this queue.
String	getDeadLetterAddress() Returns the dead-letter address associated to this queue.
String	getExpiryAddress() Returns the expiry address associated to this queue.
String[]	getJNDIBindings() Returns the JNDI bindings associated to this connection factory.
long	getScheduledCount() Returns the number of scheduled messages in this queue.
String	getSelector() returns the selector for the queue
boolean	isPaused() Returns whether the queue is paused.
String	listConsumersAsJSON()
String	listMessageCounter() Lists the message counter for this queue.
String	listMessageCounterAsHTML() Lists the message counter for this queue as a HTML table.
String	listMessageCounterHistory() Lists the message counter history for this queue.
String	listMessageCounterHistoryAsHTML() Lists the message counter history for this queue as a HTML table.
Map<String,Object>[]	listMessages(String filter) Lists all the JMS messages in this queue matching the specified filter.
String	listMessagesAsJSON(String filter) Lists all the JMS messages in this queue matching the specified filter using JSON serialization.
boolean	moveMessage(String messageID, String otherQueueName) Moves the message corresponding to the specified message ID to the specified other queue.
boolean	moveMessage(String messageID, String otherQueueName, boolean rejectDuplicates) Moves the message corresponding to the specified message ID to the specified other queue.
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	removeJNDI(String jndi)
boolean	removeMessage(String messageID) Removes the message corresponding to the specified message ID.
int	removeMessages(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(String filterStr) Sends all the message corresponding to the specified filter to this queue's dead letter address.
boolean	sendMessageToDeadLetterAddress(String messageID) Sends the message corresponding to the specified message ID to this queue's dead letter address.
void	setDeadLetterAddress(String deadLetterAddress) Sets the dead-letter address associated to this queue to the specified deadLetterAddress.
void	setExpiryAddress(String expiryAddress) Sets the expiry address associated to this queue to the specified expiryAddress.

Methods inherited from interface org.hornetq.api.jms.management.DestinationControl

getAddress, getDeliveringCount, getMessageCount, getMessagesAdded, getName, isTemporary

Method Detail

getExpiryAddress

String getExpiryAddress()

Returns the expiry address associated to this queue.

setExpiryAddress

void setExpiryAddress(String expiryAddress)
                      throws Exception

Sets the expiry address associated to this queue to the specified expiryAddress.

Throws:

Exception

getDeadLetterAddress

String getDeadLetterAddress()

Returns the dead-letter address associated to this queue.

setDeadLetterAddress

void setDeadLetterAddress(String deadLetterAddress)
                          throws Exception

Sets the dead-letter address associated to this queue to the specified deadLetterAddress.

Throws:

Exception

getScheduledCount

long getScheduledCount()

Returns the number of scheduled messages in this queue.

getConsumerCount

int getConsumerCount()

Returns the number of consumers consuming messages from this queue.

getSelector

String getSelector()

returns the selector for the queue

getJNDIBindings

String[] getJNDIBindings()

Returns the JNDI bindings associated to this connection factory.

addJNDI

void addJNDI(String jndi)
             throws Exception

Add the JNDI binding to this destination

Throws:

Exception

removeJNDI

void removeJNDI(String jndi)
                throws Exception

Throws:

Exception

listMessages

Map<String,Object>[] listMessages(String filter)
                                  throws Exception

Lists all the JMS 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

String listMessagesAsJSON(String filter)
                          throws Exception

Lists all the JMS 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

long countMessages(String filter)
                   throws Exception

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

removeMessage

boolean removeMessage(String messageID)
                      throws Exception

Removes the message corresponding to the specified message ID.

Returns:

true if the message was removed, false else

Throws:

Exception

removeMessages

int removeMessages(String filter)
                   throws Exception

Removes all the message corresponding to the specified filter.
Using null or an empty filter will remove all messages from this queue.

Specified by:

removeMessages in interface DestinationControl

Returns:

the number of removed messages

Throws:

Exception

expireMessages

int expireMessages(String filter)
                   throws Exception

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

boolean expireMessage(String messageID)
                      throws Exception

Expires the message corresponding to the specified message ID.

Returns:

true if the message was expired, false else

Throws:

Exception

sendMessageToDeadLetterAddress

boolean sendMessageToDeadLetterAddress(String messageID)
                                       throws Exception

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

int sendMessagesToDeadLetterAddress(String filterStr)
                                    throws Exception

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

changeMessagePriority

boolean changeMessagePriority(String messageID,
                            int newPriority)
                              throws Exception

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

int changeMessagesPriority(String filter,
                         int newPriority)
                           throws Exception

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

moveMessage

boolean moveMessage(String messageID,
                  String otherQueueName)
                    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

moveMessage

boolean moveMessage(String 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

int moveMessages(String filter,
               String otherQueueName)
                 throws Exception

Moves all the message corresponding to the specified filter to the specified other queue. RejectDuplicates=false on this case
Using null or an empty filter will move all messages from this queue.

Returns:

the number of moved messages

Throws:

Exception

moveMessages

int moveMessages(String filter,
               String otherQueueName,
               boolean rejectDuplicates)
                 throws Exception

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

listMessageCounter

String listMessageCounter()
                          throws Exception

Lists the message counter for this queue.

Throws:

Exception

resetMessageCounter

void resetMessageCounter()
                         throws Exception

Resets the message counter for this queue.

Throws:

Exception

listMessageCounterAsHTML

String listMessageCounterAsHTML()
                                throws Exception

Lists the message counter for this queue as a HTML table.

Throws:

Exception

listMessageCounterHistory

String listMessageCounterHistory()
                                 throws Exception

Lists the message counter history for this queue.

Throws:

Exception

listMessageCounterHistoryAsHTML

String listMessageCounterHistoryAsHTML()
                                       throws Exception

Lists the message counter history for this queue as a HTML table.

Throws:

Exception

pause

void pause()
           throws Exception

Pauses the queue. Messages are no longer delivered to its consumers.

Throws:

Exception

isPaused

boolean isPaused()
                 throws Exception

Returns whether the queue is paused.

Throws:

Exception

resume

void resume()
            throws Exception

Resumes the queue. Messages are again delivered to its consumers.

Throws:

Exception

listConsumersAsJSON

String listConsumersAsJSON()
                           throws Exception

Throws:

Exception