org.jboss.messaging.jms.server.management.jmx.impl
Class ReplicationAwareJMSQueueControlWrapper
java.lang.Object
javax.management.StandardMBean
org.jboss.messaging.core.management.jmx.impl.ReplicationAwareStandardMBeanWrapper
org.jboss.messaging.jms.server.management.jmx.impl.ReplicationAwareJMSQueueControlWrapper
- All Implemented Interfaces:
- javax.management.DynamicMBean, DestinationControl, JMSQueueControl
public class ReplicationAwareJMSQueueControlWrapper
- extends ReplicationAwareStandardMBeanWrapper
- implements JMSQueueControl
A ReplicationAwareJMSQueueControlWrapper
- 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 |
ReplicationAwareJMSQueueControlWrapper
public ReplicationAwareJMSQueueControlWrapper(JMSQueueControlImpl localControl,
ReplicationOperationInvoker replicationInvoker)
throws java.lang.Exception
- Throws:
java.lang.Exception
getConsumerCount
public int getConsumerCount()
- Specified by:
getConsumerCount
in interface JMSQueueControl
getDeadLetterAddress
public java.lang.String getDeadLetterAddress()
- Specified by:
getDeadLetterAddress
in interface JMSQueueControl
setDeadLetterAddress
public void setDeadLetterAddress(java.lang.String deadLetterAddress)
throws java.lang.Exception
- Specified by:
setDeadLetterAddress
in interface JMSQueueControl
- Throws:
java.lang.Exception
getDeliveringCount
public int getDeliveringCount()
- Specified by:
getDeliveringCount
in interface JMSQueueControl
getExpiryAddress
public java.lang.String getExpiryAddress()
- Specified by:
getExpiryAddress
in interface JMSQueueControl
getMessageCount
public int getMessageCount()
- Specified by:
getMessageCount
in interface DestinationControl
- Specified by:
getMessageCount
in interface JMSQueueControl
getMessagesAdded
public int getMessagesAdded()
- Specified by:
getMessagesAdded
in interface JMSQueueControl
getName
public java.lang.String getName()
- Specified by:
getName
in interface DestinationControl
- Specified by:
getName
in interface JMSQueueControl
getScheduledCount
public long getScheduledCount()
- Specified by:
getScheduledCount
in interface JMSQueueControl
isDurable
public boolean isDurable()
- Specified by:
isDurable
in interface JMSQueueControl
isTemporary
public boolean isTemporary()
- Specified by:
isTemporary
in interface DestinationControl
- Specified by:
isTemporary
in interface JMSQueueControl
listMessageCounter
public java.lang.String listMessageCounter()
- Specified by:
listMessageCounter
in interface JMSQueueControl
listMessageCounterAsHTML
public java.lang.String listMessageCounterAsHTML()
- Specified by:
listMessageCounterAsHTML
in interface JMSQueueControl
listMessageCounterHistory
public java.lang.String listMessageCounterHistory()
throws java.lang.Exception
- Specified by:
listMessageCounterHistory
in interface JMSQueueControl
- Throws:
java.lang.Exception
listMessageCounterHistoryAsHTML
public java.lang.String listMessageCounterHistoryAsHTML()
- Specified by:
listMessageCounterHistoryAsHTML
in interface JMSQueueControl
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 JMSQueueControl
- Throws:
java.lang.Exception
listMessagesAsJSON
public java.lang.String listMessagesAsJSON(java.lang.String filter)
throws java.lang.Exception
- Specified by:
listMessagesAsJSON
in interface JMSQueueControl
- Throws:
java.lang.Exception
countMessages
public int countMessages(java.lang.String filter)
throws java.lang.Exception
- Specified by:
countMessages
in interface JMSQueueControl
- Throws:
java.lang.Exception
getAddress
public java.lang.String getAddress()
- Specified by:
getAddress
in interface DestinationControl
getJNDIBinding
public java.lang.String getJNDIBinding()
- Specified by:
getJNDIBinding
in interface DestinationControl
changeMessagePriority
public boolean changeMessagePriority(java.lang.String messageID,
int newPriority)
throws java.lang.Exception
- Specified by:
changeMessagePriority
in interface JMSQueueControl
- Throws:
java.lang.Exception
expireMessage
public boolean expireMessage(java.lang.String messageID)
throws java.lang.Exception
- Specified by:
expireMessage
in interface JMSQueueControl
- Throws:
java.lang.Exception
expireMessages
public int expireMessages(java.lang.String filter)
throws java.lang.Exception
- Specified by:
expireMessages
in interface JMSQueueControl
- 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 JMSQueueControl
- Throws:
java.lang.Exception
moveMessage
public boolean moveMessage(java.lang.String messageID,
java.lang.String otherQueueName)
throws java.lang.Exception
- Specified by:
moveMessage
in interface JMSQueueControl
- Throws:
java.lang.Exception
removeMessages
public int removeMessages(java.lang.String filter)
throws java.lang.Exception
- Specified by:
removeMessages
in interface DestinationControl
- Specified by:
removeMessages
in interface JMSQueueControl
- Throws:
java.lang.Exception
removeMessage
public boolean removeMessage(java.lang.String messageID)
throws java.lang.Exception
- Specified by:
removeMessage
in interface JMSQueueControl
- Throws:
java.lang.Exception
sendMessageToDeadLetterAddress
public boolean sendMessageToDeadLetterAddress(java.lang.String messageID)
throws java.lang.Exception
- Specified by:
sendMessageToDeadLetterAddress
in interface JMSQueueControl
- Throws:
java.lang.Exception
setExpiryAddress
public void setExpiryAddress(java.lang.String expiryAddress)
throws java.lang.Exception
- Specified by:
setExpiryAddress
in interface JMSQueueControl
- 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.