public class QueueControlImpl extends AbstractControl implements QueueControl
Modifier and Type | Field and Description |
---|---|
static int |
FLUSH_LIMIT |
Constructor and Description |
---|
QueueControlImpl(Queue queue,
String address,
PostOffice postOffice,
StorageManager storageManager,
SecurityStore securityStore,
HierarchicalRepository<AddressSettings> addressSettingsRepository) |
blockOnIO, clearIO, getMBeanInfo
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 static final int FLUSH_LIMIT
public QueueControlImpl(Queue queue, String address, PostOffice postOffice, StorageManager storageManager, SecurityStore securityStore, HierarchicalRepository<AddressSettings> addressSettingsRepository) throws Exception
Exception
public void setMessageCounter(MessageCounter counter)
public String getName()
getName
in interface QueueControl
public String getAddress()
getAddress
in interface QueueControl
public String getFilter()
getFilter
in interface QueueControl
public boolean isDurable()
isDurable
in interface QueueControl
public boolean isTemporary()
isTemporary
in interface QueueControl
public long getMessageCount()
getMessageCount
in interface QueueControl
public int getConsumerCount()
getConsumerCount
in interface QueueControl
public int getDeliveringCount()
getDeliveringCount
in interface QueueControl
public long getMessagesAdded()
getMessagesAdded
in interface QueueControl
public long getMessagesAcknowledged()
getMessagesAcknowledged
in interface QueueControl
public long getMessagesExpired()
getMessagesExpired
in interface QueueControl
public long getMessagesKilled()
getMessagesKilled
in interface QueueControl
public long getID()
getID
in interface QueueControl
public long getScheduledCount()
getScheduledCount
in interface QueueControl
public String getDeadLetterAddress()
getDeadLetterAddress
in interface QueueControl
public String getExpiryAddress()
getExpiryAddress
in interface QueueControl
public Map<String,Object>[] listScheduledMessages() throws Exception
listScheduledMessages
in interface QueueControl
Exception
public String listScheduledMessagesAsJSON() throws Exception
listScheduledMessagesAsJSON
in interface QueueControl
Exception
public Map<String,Map<String,Object>[]> listDeliveringMessages() throws ActiveMQException
listDeliveringMessages
in interface QueueControl
ActiveMQException
public String listDeliveringMessagesAsJSON() throws Exception
listDeliveringMessagesAsJSON
in interface QueueControl
Exception
public Map<String,Object>[] listMessages(String filterStr) throws Exception
listMessages
in interface QueueControl
Exception
public String listMessagesAsJSON(String filter) throws Exception
listMessagesAsJSON
in interface QueueControl
Exception
public String getFirstMessageAsJSON() throws Exception
getFirstMessageAsJSON
in interface QueueControl
Exception
public Long getFirstMessageTimestamp() throws Exception
getFirstMessageTimestamp
in interface QueueControl
Exception
public Long getFirstMessageAge() throws Exception
getFirstMessageAge
in interface QueueControl
Exception
public long countMessages(String filterStr) throws Exception
countMessages
in interface QueueControl
Exception
public boolean removeMessage(long messageID) throws Exception
removeMessage
in interface QueueControl
Exception
public int removeMessages(String filterStr) throws Exception
removeMessages
in interface QueueControl
Exception
public int removeMessages(int flushLimit, String filterStr) throws Exception
removeMessages
in interface QueueControl
Exception
public boolean expireMessage(long messageID) throws Exception
expireMessage
in interface QueueControl
Exception
public int expireMessages(String filterStr) throws Exception
expireMessages
in interface QueueControl
Exception
public boolean retryMessage(long messageID) throws Exception
retryMessage
in interface QueueControl
Exception
public int retryMessages() throws Exception
retryMessages
in interface QueueControl
Exception
public boolean moveMessage(long messageID, String otherQueueName) throws Exception
moveMessage
in interface QueueControl
Exception
public boolean moveMessage(long messageID, String otherQueueName, boolean rejectDuplicates) throws Exception
moveMessage
in interface QueueControl
Exception
public int moveMessages(String filterStr, String otherQueueName) throws Exception
moveMessages
in interface QueueControl
Exception
public int moveMessages(int flushLimit, String filterStr, String otherQueueName, boolean rejectDuplicates) throws Exception
moveMessages
in interface QueueControl
Exception
public int moveMessages(String filterStr, String otherQueueName, boolean rejectDuplicates) throws Exception
moveMessages
in interface QueueControl
Exception
public int sendMessagesToDeadLetterAddress(String filterStr) throws Exception
sendMessagesToDeadLetterAddress
in interface QueueControl
Exception
public String sendMessage(Map<String,String> headers, int type, String body, String userID, boolean durable, String user, String password) throws Exception
sendMessage
in interface QueueControl
Exception
public boolean sendMessageToDeadLetterAddress(long messageID) throws Exception
sendMessageToDeadLetterAddress
in interface QueueControl
Exception
public int changeMessagesPriority(String filterStr, int newPriority) throws Exception
changeMessagesPriority
in interface QueueControl
Exception
public boolean changeMessagePriority(long messageID, int newPriority) throws Exception
changeMessagePriority
in interface QueueControl
Exception
public String listMessageCounter()
listMessageCounter
in interface QueueControl
public void resetMessageCounter()
resetMessageCounter
in interface QueueControl
public String listMessageCounterAsHTML()
listMessageCounterAsHTML
in interface QueueControl
public String listMessageCounterHistory() throws Exception
listMessageCounterHistory
in interface QueueControl
Exception
public String listMessageCounterHistoryAsHTML()
listMessageCounterHistoryAsHTML
in interface QueueControl
public void pause()
pause
in interface QueueControl
public void pause(boolean persist)
pause
in interface QueueControl
public void resume()
resume
in interface QueueControl
public boolean isPaused() throws Exception
isPaused
in interface QueueControl
Exception
public CompositeData[] browse(String filterStr) throws Exception
browse
in interface QueueControl
Exception
public void flushExecutor()
flushExecutor
in interface QueueControl
public String listConsumersAsJSON() throws Exception
listConsumersAsJSON
in interface QueueControl
Exception
protected MBeanOperationInfo[] fillMBeanOperationInfo()
fillMBeanOperationInfo
in class AbstractControl
protected MBeanAttributeInfo[] fillMBeanAttributeInfo()
fillMBeanAttributeInfo
in class AbstractControl
public void resetMessagesAdded() throws Exception
resetMessagesAdded
in interface QueueControl
Exception
public void resetMessagesAcknowledged() throws Exception
resetMessagesAcknowledged
in interface QueueControl
Exception
public void resetMessagesExpired() throws Exception
resetMessagesExpired
in interface QueueControl
Exception
public void resetMessagesKilled() throws Exception
resetMessagesKilled
in interface QueueControl
Exception
Copyright © 2018 The Apache Software Foundation. All Rights Reserved.