org.jboss.messaging.core.management.jmx.impl
Class ReplicationAwareQueueControlWrapper
java.lang.Object
javax.management.StandardMBean
org.jboss.messaging.core.management.jmx.impl.ReplicationAwareStandardMBeanWrapper
org.jboss.messaging.core.management.jmx.impl.ReplicationAwareQueueControlWrapper
- All Implemented Interfaces:
- javax.management.DynamicMBean, QueueControl
public class ReplicationAwareQueueControlWrapper
- extends ReplicationAwareStandardMBeanWrapper
- implements QueueControl
A ReplicationAwareQueueControlWrapper
- Author:
- Jeff Mesnil
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, setAttribute, setAttributes, setImplementation |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ReplicationAwareQueueControlWrapper
public ReplicationAwareQueueControlWrapper(QueueControlImpl localControl,
ReplicationOperationInvoker replicationInvoker)
throws java.lang.Exception
- Throws:
java.lang.Exception
getConsumerCount
public int getConsumerCount()
- Specified by:
getConsumerCount
in interface QueueControl
getDeadLetterAddress
public java.lang.String getDeadLetterAddress()
- Specified by:
getDeadLetterAddress
in interface QueueControl
setDeadLetterAddress
public void setDeadLetterAddress(java.lang.String deadLetterAddress)
throws java.lang.Exception
- Specified by:
setDeadLetterAddress
in interface QueueControl
- Throws:
java.lang.Exception
getDeliveringCount
public int getDeliveringCount()
- Specified by:
getDeliveringCount
in interface QueueControl
getExpiryAddress
public java.lang.String getExpiryAddress()
- Specified by:
getExpiryAddress
in interface QueueControl
setExpiryAddress
public void setExpiryAddress(java.lang.String expiryAddres)
throws java.lang.Exception
- Specified by:
setExpiryAddress
in interface QueueControl
- Throws:
java.lang.Exception
getFilter
public java.lang.String getFilter()
- Specified by:
getFilter
in interface QueueControl
getMessageCount
public int getMessageCount()
- Specified by:
getMessageCount
in interface QueueControl
getMessagesAdded
public int getMessagesAdded()
- Specified by:
getMessagesAdded
in interface QueueControl
getName
public java.lang.String getName()
- Specified by:
getName
in interface QueueControl
getAddress
public java.lang.String getAddress()
- Specified by:
getAddress
in interface QueueControl
getPersistenceID
public long getPersistenceID()
- Specified by:
getPersistenceID
in interface QueueControl
getScheduledCount
public long getScheduledCount()
- Specified by:
getScheduledCount
in interface QueueControl
isBackup
public boolean isBackup()
- Specified by:
isBackup
in interface QueueControl
isDurable
public boolean isDurable()
- Specified by:
isDurable
in interface QueueControl
isTemporary
public boolean isTemporary()
- Specified by:
isTemporary
in interface QueueControl
listMessageCounter
public java.lang.String listMessageCounter()
throws java.lang.Exception
- Specified by:
listMessageCounter
in interface QueueControl
- Throws:
java.lang.Exception
resetMessageCounter
public void resetMessageCounter()
throws java.lang.Exception
- Specified by:
resetMessageCounter
in interface QueueControl
- Throws:
java.lang.Exception
listMessageCounterAsHTML
public java.lang.String listMessageCounterAsHTML()
throws java.lang.Exception
- Specified by:
listMessageCounterAsHTML
in interface QueueControl
- Throws:
java.lang.Exception
listMessageCounterHistory
public java.lang.String listMessageCounterHistory()
throws java.lang.Exception
- Specified by:
listMessageCounterHistory
in interface QueueControl
- Throws:
java.lang.Exception
listMessageCounterHistoryAsHTML
public java.lang.String listMessageCounterHistoryAsHTML()
throws java.lang.Exception
- Specified by:
listMessageCounterHistoryAsHTML
in interface QueueControl
- Throws:
java.lang.Exception
listMessages
public java.util.Map<java.lang.String,java.lang.Object>[] listMessages(java.lang.String filter)
throws java.lang.Exception
- Specified by:
listMessages
in interface QueueControl
- Throws:
java.lang.Exception
listMessagesAsJSON
public java.lang.String listMessagesAsJSON(java.lang.String filter)
throws java.lang.Exception
- Specified by:
listMessagesAsJSON
in interface QueueControl
- Throws:
java.lang.Exception
countMessages
public int countMessages(java.lang.String filter)
throws java.lang.Exception
- Specified by:
countMessages
in interface QueueControl
- Throws:
java.lang.Exception
listScheduledMessages
public java.util.Map<java.lang.String,java.lang.Object>[] listScheduledMessages()
throws java.lang.Exception
- Specified by:
listScheduledMessages
in interface QueueControl
- Throws:
java.lang.Exception
listScheduledMessagesAsJSON
public java.lang.String listScheduledMessagesAsJSON()
throws java.lang.Exception
- Specified by:
listScheduledMessagesAsJSON
in interface QueueControl
- Throws:
java.lang.Exception
changeMessagePriority
public boolean changeMessagePriority(long messageID,
int newPriority)
throws java.lang.Exception
- Specified by:
changeMessagePriority
in interface QueueControl
- Throws:
java.lang.Exception
changeMessagesPriority
public int changeMessagesPriority(java.lang.String filter,
int newPriority)
throws java.lang.Exception
- Specified by:
changeMessagesPriority
in interface QueueControl
- Throws:
java.lang.Exception
expireMessage
public boolean expireMessage(long messageID)
throws java.lang.Exception
- Specified by:
expireMessage
in interface QueueControl
- Throws:
java.lang.Exception
expireMessages
public int expireMessages(java.lang.String filter)
throws java.lang.Exception
- Specified by:
expireMessages
in interface QueueControl
- Throws:
java.lang.Exception
moveMessages
public int moveMessages(java.lang.String filter,
java.lang.String otherQueueName)
throws java.lang.Exception
- Specified by:
moveMessages
in interface QueueControl
- Throws:
java.lang.Exception
moveMessage
public boolean moveMessage(long messageID,
java.lang.String otherQueueName)
throws java.lang.Exception
- Specified by:
moveMessage
in interface QueueControl
- Throws:
java.lang.Exception
removeMessages
public int removeMessages(java.lang.String filter)
throws java.lang.Exception
- Specified by:
removeMessages
in interface QueueControl
- Throws:
java.lang.Exception
removeMessage
public boolean removeMessage(long messageID)
throws java.lang.Exception
- Specified by:
removeMessage
in interface QueueControl
- Throws:
java.lang.Exception
sendMessageToDeadLetterAddress
public boolean sendMessageToDeadLetterAddress(long messageID)
throws java.lang.Exception
- Specified by:
sendMessageToDeadLetterAddress
in interface QueueControl
- Throws:
java.lang.Exception
sendMessagesToDeadLetterAddress
public int sendMessagesToDeadLetterAddress(java.lang.String filterStr)
throws java.lang.Exception
- Specified by:
sendMessagesToDeadLetterAddress
in interface QueueControl
- Throws:
java.lang.Exception
getMBeanInfo
public javax.management.MBeanInfo getMBeanInfo()
- Specified by:
getMBeanInfo
in interface javax.management.DynamicMBean
- Overrides:
getMBeanInfo
in class javax.management.StandardMBean
Copyright © 2006 JBoss Inc. All Rights Reserved.