public class JMSQueueControlImpl extends StandardMBean implements JMSQueueControl
Constructor and Description |
---|
JMSQueueControlImpl(HornetQDestination managedQueue,
QueueControl coreQueueControl,
JMSServerManager jmsServerManager,
org.hornetq.core.messagecounter.MessageCounter counter) |
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
public JMSQueueControlImpl(HornetQDestination managedQueue, QueueControl coreQueueControl, JMSServerManager jmsServerManager, org.hornetq.core.messagecounter.MessageCounter counter) throws Exception
Exception
public static String createFilterFromJMSSelector(String selectorStr) throws HornetQException
HornetQException
public String getName()
getName
in interface DestinationControl
public String getAddress()
getAddress
in interface DestinationControl
public boolean isTemporary()
isTemporary
in interface DestinationControl
public long getMessageCount()
getMessageCount
in interface DestinationControl
public long getMessagesAdded()
getMessagesAdded
in interface DestinationControl
public int getConsumerCount()
getConsumerCount
in interface JMSQueueControl
public int getDeliveringCount()
getDeliveringCount
in interface DestinationControl
public long getScheduledCount()
getScheduledCount
in interface JMSQueueControl
public boolean isDurable()
public String getDeadLetterAddress()
getDeadLetterAddress
in interface JMSQueueControl
public void setDeadLetterAddress(String deadLetterAddress) throws Exception
setDeadLetterAddress
in interface JMSQueueControl
Exception
public String getExpiryAddress()
getExpiryAddress
in interface JMSQueueControl
public void setExpiryAddress(String expiryAddress) throws Exception
setExpiryAddress
in interface JMSQueueControl
Exception
public void addJNDI(String jndi) throws Exception
addJNDI
in interface JMSQueueControl
Exception
public String[] getJNDIBindings()
getJNDIBindings
in interface JMSQueueControl
public boolean removeMessage(String messageID) throws Exception
removeMessage
in interface JMSQueueControl
Exception
public int removeMessages(String filterStr) throws Exception
removeMessages
in interface DestinationControl
removeMessages
in interface JMSQueueControl
Exception
public Map<String,Object>[] listMessages(String filterStr) throws Exception
listMessages
in interface JMSQueueControl
Exception
public String listMessagesAsJSON(String filter) throws Exception
listMessagesAsJSON
in interface JMSQueueControl
Exception
public long countMessages(String filterStr) throws Exception
countMessages
in interface JMSQueueControl
Exception
public boolean expireMessage(String messageID) throws Exception
expireMessage
in interface JMSQueueControl
Exception
public int expireMessages(String filterStr) throws Exception
expireMessages
in interface JMSQueueControl
Exception
public boolean sendMessageToDeadLetterAddress(String messageID) throws Exception
sendMessageToDeadLetterAddress
in interface JMSQueueControl
Exception
public int sendMessagesToDeadLetterAddress(String filterStr) throws Exception
sendMessagesToDeadLetterAddress
in interface JMSQueueControl
Exception
public boolean changeMessagePriority(String messageID, int newPriority) throws Exception
changeMessagePriority
in interface JMSQueueControl
Exception
public int changeMessagesPriority(String filterStr, int newPriority) throws Exception
changeMessagesPriority
in interface JMSQueueControl
Exception
public boolean moveMessage(String messageID, String otherQueueName) throws Exception
moveMessage
in interface JMSQueueControl
Exception
public boolean moveMessage(String messageID, String otherQueueName, boolean rejectDuplicates) throws Exception
moveMessage
in interface JMSQueueControl
Exception
public int moveMessages(String filterStr, String otherQueueName, boolean rejectDuplicates) throws Exception
moveMessages
in interface JMSQueueControl
Exception
public int moveMessages(String filterStr, String otherQueueName) throws Exception
moveMessages
in interface JMSQueueControl
Exception
public String listConsumersAsJSON() throws Exception
listConsumersAsJSON
in interface JMSQueueControl
Exception
public String listMessageCounter()
listMessageCounter
in interface JMSQueueControl
public void resetMessageCounter() throws Exception
resetMessageCounter
in interface JMSQueueControl
Exception
public String listMessageCounterAsHTML()
listMessageCounterAsHTML
in interface JMSQueueControl
public String listMessageCounterHistory() throws Exception
listMessageCounterHistory
in interface JMSQueueControl
Exception
public String listMessageCounterHistoryAsHTML()
listMessageCounterHistoryAsHTML
in interface JMSQueueControl
public boolean isPaused() throws Exception
isPaused
in interface JMSQueueControl
Exception
public void pause() throws Exception
pause
in interface JMSQueueControl
Exception
public void resume() throws Exception
resume
in interface JMSQueueControl
Exception
public String getSelector()
getSelector
in interface JMSQueueControl
public MBeanInfo getMBeanInfo()
getMBeanInfo
in interface DynamicMBean
getMBeanInfo
in class StandardMBean
Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.