org.hornetq.core.management.impl

Class QueueControlImpl

java.lang.Object

javax.management.StandardMBean

org.hornetq.core.management.impl.AbstractControl

org.hornetq.core.management.impl.QueueControlImpl

All Implemented Interfaces:

DynamicMBean, MBeanRegistration, QueueControl

public class QueueControlImpl
extends AbstractControl
implements QueueControl

Version:

$Revision$

Author:

Jeff Mesnil

Field Summary

Fields inherited from class org.hornetq.core.management.impl.AbstractControl

storageManager

Constructor Summary

Constructors

Constructor and Description
QueueControlImpl(Queue queue, String address, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	changeMessagePriority(long messageID, int newPriority) Changes the message's priority corresponding to the specified message ID to the specified priority.
int	changeMessagesPriority(String filterStr, int newPriority) Changes the priority for all the message corresponding to the specified filter to the specified priority.
long	countMessages(String filterStr) Counts the number of messages in this queue matching the specified filter.
boolean	expireMessage(long messageID) Expires the message corresponding to the specified message ID.
int	expireMessages(String filterStr) Expires all the message corresponding to the specified filter.
protected MBeanOperationInfo[]	fillMBeanOperationInfo()
String	getAddress() Returns the address this queue is bound to.
int	getConsumerCount() Returns the number of consumers consuming messages from this queue.
String	getDeadLetterAddress() Returns the dead-letter address associated to this queue.
int	getDeliveringCount() Returns the number of messages that this queue is currently delivering to its consumers.
String	getExpiryAddress() Returns the expiry address associated to this queue.
String	getFilter() Returns the filter associated to this queue.
long	getID() Returns this queue ID.
long	getMessageCount() Returns the number of messages currently in this queue.
long	getMessagesAdded() Returns the number of messages added to this queue since it was created.
String	getName() Returns the name of this queue.
long	getScheduledCount() Returns the number of scheduled messages in this queue.
boolean	isDurable() Returns whether this queue is durable.
boolean	isPaused() Returns whether the queue is paused.
boolean	isTemporary() Returns whether this queue is temporary.
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 filterStr) Lists all the messages in this queue matching the specified filter.
String	listMessagesAsJSON(String filter) Lists all the messages in this queue matching the specified filter using JSON serialization.
Map<String,Object>[]	listScheduledMessages() Lists all the messages scheduled for delivery for this queue.
String	listScheduledMessagesAsJSON() 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(String filterStr, String otherQueueName) Moves all the message corresponding to the specified filter to the specified other queue.
int	moveMessages(String filterStr, String otherQueueName, boolean rejectDuplicates) Moves all the message corresponding to the specified filter to the specified other queue.
void	pause() Pauses the queue.
boolean	removeMessage(long messageID) Removes the message corresponding to the specified message ID.
int	removeMessages(String filterStr) 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(long 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.
void	setMessageCounter(MessageCounter counter)

Methods inherited from class org.hornetq.core.management.impl.AbstractControl

blockOnIO, clearIO, getMBeanInfo

Methods inherited from class javax.management.StandardMBean

cacheMBeanInfo, getAttribute, getAttributes, getCachedMBeanInfo, getClassName, getConstructors, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getImpact, getImplementation, getImplementationClass, getMBeanInterface, getParameterName, getParameterName, invoke, postDeregister, postRegister, preDeregister, preRegister, setAttribute, setAttributes, setImplementation

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QueueControlImpl

public QueueControlImpl(Queue queue,
                String address,
                PostOffice postOffice,
                StorageManager storageManager,
                HierarchicalRepository<AddressSettings> addressSettingsRepository)
                 throws Exception

Throws:

Exception

Method Detail

setMessageCounter

public void setMessageCounter(MessageCounter counter)

getName

public String getName()

Description copied from interface: QueueControl

Returns the name of this queue.

Specified by:

getName in interface QueueControl

getAddress

public String getAddress()

Description copied from interface: QueueControl

Returns the address this queue is bound to.

Specified by:

getAddress in interface QueueControl

getFilter

public String getFilter()

Description copied from interface: QueueControl

Returns the filter associated to this queue.

Specified by:

getFilter in interface QueueControl

isDurable

public boolean isDurable()

Description copied from interface: QueueControl

Returns whether this queue is durable.

Specified by:

isDurable in interface QueueControl

isTemporary

public boolean isTemporary()

Description copied from interface: QueueControl

Returns whether this queue is temporary.

Specified by:

isTemporary in interface QueueControl

getMessageCount

public long getMessageCount()

Description copied from interface: QueueControl

Returns the number of messages currently in this queue.

Specified by:

getMessageCount in interface QueueControl

getConsumerCount

public int getConsumerCount()

Description copied from interface: QueueControl

Returns the number of consumers consuming messages from this queue.

Specified by:

getConsumerCount in interface QueueControl

getDeliveringCount

public int getDeliveringCount()

Description copied from interface: QueueControl

Returns the number of messages that this queue is currently delivering to its consumers.

Specified by:

getDeliveringCount in interface QueueControl

getMessagesAdded

public long getMessagesAdded()

Description copied from interface: QueueControl

Returns the number of messages added to this queue since it was created.

Specified by:

getMessagesAdded in interface QueueControl

getID

public long getID()

Description copied from interface: QueueControl

Returns this queue ID.

Specified by:

getID in interface QueueControl

getScheduledCount

public long getScheduledCount()

Description copied from interface: QueueControl

Returns the number of scheduled messages in this queue.

Specified by:

getScheduledCount in interface QueueControl

getDeadLetterAddress

public String getDeadLetterAddress()

Description copied from interface: QueueControl

Returns the dead-letter address associated to this queue.

Specified by:

getDeadLetterAddress in interface QueueControl

setDeadLetterAddress

public void setDeadLetterAddress(String deadLetterAddress)
                          throws Exception

Description copied from interface: QueueControl

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

Specified by:

setDeadLetterAddress in interface QueueControl

Throws:

Exception

getExpiryAddress

public String getExpiryAddress()

Description copied from interface: QueueControl

Returns the expiry address associated to this queue.

Specified by:

getExpiryAddress in interface QueueControl

setExpiryAddress

public void setExpiryAddress(String expiryAddress)
                      throws Exception

Description copied from interface: QueueControl

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

Specified by:

setExpiryAddress in interface QueueControl

Throws:

Exception

listScheduledMessages

public Map<String,Object>[] listScheduledMessages()
                                           throws Exception

Description copied from interface: QueueControl

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.

Specified by:

listScheduledMessages in interface QueueControl

Throws:

Exception

listScheduledMessagesAsJSON

public String listScheduledMessagesAsJSON()
                                   throws Exception

Description copied from interface: QueueControl

Lists all the messages scheduled for delivery for this queue using JSON serialization.

Specified by:

listScheduledMessagesAsJSON in interface QueueControl

Throws:

Exception

listMessages

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

Description copied from interface: QueueControl

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.

Specified by:

listMessages in interface QueueControl

Throws:

Exception

listMessagesAsJSON

public String listMessagesAsJSON(String filter)
                          throws Exception

Description copied from interface: QueueControl

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.

Specified by:

listMessagesAsJSON in interface QueueControl

Throws:

Exception

countMessages

public long countMessages(String filterStr)
                   throws Exception

Description copied from interface: QueueControl

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.

Specified by:

countMessages in interface QueueControl

Throws:

Exception

removeMessage

public boolean removeMessage(long messageID)
                      throws Exception

Description copied from interface: QueueControl

Removes the message corresponding to the specified message ID.

Specified by:

removeMessage in interface QueueControl

Returns:

true if the message was removed, false else

Throws:

Exception

removeMessages

public int removeMessages(String filterStr)
                   throws Exception

Description copied from interface: QueueControl

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 QueueControl

Returns:

the number of removed messages

Throws:

Exception

expireMessage

public boolean expireMessage(long messageID)
                      throws Exception

Description copied from interface: QueueControl

Expires the message corresponding to the specified message ID.

Specified by:

expireMessage in interface QueueControl

Returns:

true if the message was expired, false else

Throws:

Exception

expireMessages

public int expireMessages(String filterStr)
                   throws Exception

Description copied from interface: QueueControl

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

Specified by:

expireMessages in interface QueueControl

Returns:

the number of expired messages

Throws:

Exception

moveMessage

public boolean moveMessage(long messageID,
                  String otherQueueName)
                    throws Exception

Description copied from interface: QueueControl

Moves the message corresponding to the specified message ID to the specified other queue.

Specified by:

moveMessage in interface QueueControl

Returns:

true if the message was moved, false else

Throws:

Exception

moveMessage

public boolean moveMessage(long messageID,
                  String otherQueueName,
                  boolean rejectDuplicates)
                    throws Exception

Description copied from interface: QueueControl

Moves the message corresponding to the specified message ID to the specified other queue.

Specified by:

moveMessage in interface QueueControl

Returns:

true if the message was moved, false else

Throws:

Exception

moveMessages

public int moveMessages(String filterStr,
               String otherQueueName)
                 throws Exception

Description copied from interface: QueueControl

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.

Specified by:

moveMessages in interface QueueControl

Returns:

the number of moved messages

Throws:

Exception

moveMessages

public int moveMessages(String filterStr,
               String otherQueueName,
               boolean rejectDuplicates)
                 throws Exception

Description copied from interface: QueueControl

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.

Specified by:

moveMessages in interface QueueControl

Returns:

the number of moved messages

Throws:

Exception

sendMessagesToDeadLetterAddress

public int sendMessagesToDeadLetterAddress(String filterStr)
                                    throws Exception

Description copied from interface: QueueControl

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.

Specified by:

sendMessagesToDeadLetterAddress in interface QueueControl

Returns:

the number of sent messages

Throws:

Exception

sendMessageToDeadLetterAddress

public boolean sendMessageToDeadLetterAddress(long messageID)
                                       throws Exception

Description copied from interface: QueueControl

Sends the message corresponding to the specified message ID to this queue's dead letter address.

Specified by:

sendMessageToDeadLetterAddress in interface QueueControl

Returns:

true if the message was sent to the dead letter address, false else

Throws:

Exception

changeMessagesPriority

public int changeMessagesPriority(String filterStr,
                         int newPriority)
                           throws Exception

Description copied from interface: QueueControl

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.

Specified by:

changeMessagesPriority in interface QueueControl

Returns:

the number of changed messages

Throws:

Exception

changeMessagePriority

public boolean changeMessagePriority(long messageID,
                            int newPriority)
                              throws Exception

Description copied from interface: QueueControl

Changes the message's priority corresponding to the specified message ID to the specified priority.

Specified by:

changeMessagePriority in interface QueueControl

newPriority - between 0 and 9 inclusive.

Returns:

true if the message priority was changed

Throws:

Exception

listMessageCounter

public String listMessageCounter()

Description copied from interface: QueueControl

Lists the message counter for this queue.

Specified by:

listMessageCounter in interface QueueControl

resetMessageCounter

public void resetMessageCounter()

Description copied from interface: QueueControl

Resets the message counter for this queue.

Specified by:

resetMessageCounter in interface QueueControl

listMessageCounterAsHTML

public String listMessageCounterAsHTML()

Description copied from interface: QueueControl

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

Specified by:

listMessageCounterAsHTML in interface QueueControl

listMessageCounterHistory

public String listMessageCounterHistory()
                                 throws Exception

Description copied from interface: QueueControl

Lists the message counter history for this queue.

Specified by:

listMessageCounterHistory in interface QueueControl

Throws:

Exception

listMessageCounterHistoryAsHTML

public String listMessageCounterHistoryAsHTML()

Description copied from interface: QueueControl

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

Specified by:

listMessageCounterHistoryAsHTML in interface QueueControl

pause

public void pause()

Description copied from interface: QueueControl

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

Specified by:

pause in interface QueueControl

resume

public void resume()

Description copied from interface: QueueControl

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

Specified by:

resume in interface QueueControl

isPaused

public boolean isPaused()
                 throws Exception

Description copied from interface: QueueControl

Returns whether the queue is paused.

Specified by:

isPaused in interface QueueControl

Throws:

Exception

listConsumersAsJSON

public String listConsumersAsJSON()
                           throws Exception

Specified by:

listConsumersAsJSON in interface QueueControl

Throws:

Exception

fillMBeanOperationInfo

protected MBeanOperationInfo[] fillMBeanOperationInfo()

Specified by:

fillMBeanOperationInfo in class AbstractControl