public class QueueControlImpl extends AbstractControl implements QueueControl
Modifier and Type | Field and Description |
---|---|
static int |
FLUSH_LIMIT |
storageManager
Constructor and Description |
---|
QueueControlImpl(Queue queue,
String address,
PostOffice postOffice,
StorageManager storageManager,
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, 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 getID()
getID
in interface QueueControl
public long getScheduledCount()
getScheduledCount
in interface QueueControl
public String getDeadLetterAddress()
getDeadLetterAddress
in interface QueueControl
public void setDeadLetterAddress(String deadLetterAddress) throws Exception
setDeadLetterAddress
in interface QueueControl
Exception
public String getExpiryAddress()
getExpiryAddress
in interface QueueControl
public void setExpiryAddress(String expiryAddress) throws Exception
setExpiryAddress
in interface QueueControl
Exception
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()
listDeliveringMessages
in interface QueueControl
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 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 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 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 resume()
resume
in interface QueueControl
public boolean isPaused() throws Exception
isPaused
in interface QueueControl
Exception
public String listConsumersAsJSON() throws Exception
listConsumersAsJSON
in interface QueueControl
Exception
protected MBeanOperationInfo[] fillMBeanOperationInfo()
fillMBeanOperationInfo
in class AbstractControl
public void resetMessagesAdded() throws Exception
resetMessagesAdded
in interface QueueControl
Exception
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.