public class JMSQueueControlImpl extends StandardMBean implements JMSQueueControl
Constructor and Description |
---|
JMSQueueControlImpl(ActiveMQDestination managedQueue,
QueueControl coreQueueControl,
JMSServerManager jmsServerManager,
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(ActiveMQDestination managedQueue, QueueControl coreQueueControl, JMSServerManager jmsServerManager, MessageCounter counter) throws Exception
Exception
public static String createFilterFromJMSSelector(String selectorStr) throws ActiveMQException
ActiveMQException
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 long getMessagesExpired()
getMessagesExpired
in interface JMSQueueControl
public long getMessagesKilled()
getMessagesKilled
in interface JMSQueueControl
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 String getExpiryAddress()
getExpiryAddress
in interface JMSQueueControl
public String getFirstMessageAsJSON() throws Exception
getFirstMessageAsJSON
in interface JMSQueueControl
Exception
public Long getFirstMessageTimestamp() throws Exception
getFirstMessageTimestamp
in interface JMSQueueControl
Exception
public Long getFirstMessageAge() throws Exception
getFirstMessageAge
in interface JMSQueueControl
Exception
public void addBinding(String binding) throws Exception
addBinding
in interface JMSQueueControl
Exception
public String[] getRegistryBindings()
getRegistryBindings
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 Map<String,Object>[] listScheduledMessages() throws Exception
listScheduledMessages
in interface JMSQueueControl
Exception
public String listScheduledMessagesAsJSON() throws Exception
listScheduledMessagesAsJSON
in interface JMSQueueControl
Exception
public Map<String,Map<String,Object>[]> listDeliveringMessages() throws Exception
listDeliveringMessages
in interface JMSQueueControl
Exception
public String listDeliveringMessagesAsJSON() throws Exception
listDeliveringMessagesAsJSON
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 String sendTextMessageWithProperties(String properties) throws Exception
sendTextMessageWithProperties
in interface JMSQueueControl
Exception
public String sendTextMessage(String body) throws Exception
sendTextMessage
in interface JMSQueueControl
Exception
public String sendTextMessage(Map<String,String> headers, String body) throws Exception
sendTextMessage
in interface JMSQueueControl
Exception
public String sendTextMessage(String body, String user, String password) throws Exception
sendTextMessage
in interface JMSQueueControl
Exception
public String sendTextMessage(Map<String,String> headers, String body, String user, String password) throws Exception
sendTextMessage
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 retryMessage(String jmsMessageID) throws Exception
retryMessage
in interface JMSQueueControl
Exception
public int retryMessages() throws Exception
retryMessages
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 pause(boolean persist) throws Exception
pause
in interface JMSQueueControl
Exception
public void resume() throws Exception
resume
in interface JMSQueueControl
Exception
public CompositeData[] browse() throws Exception
browse
in interface JMSQueueControl
Exception
public CompositeData[] browse(String filter) throws Exception
browse
in interface JMSQueueControl
Exception
public String getSelector()
getSelector
in interface JMSQueueControl
public void flushExecutor()
flushExecutor
in interface JMSQueueControl
public MBeanInfo getMBeanInfo()
getMBeanInfo
in interface DynamicMBean
getMBeanInfo
in class StandardMBean
Copyright © 2018 The Apache Software Foundation. All Rights Reserved.