QueueControlImpl (ActiveMQ Artemis Server 1.5.0 API)

java.lang.Object
- javax.management.StandardMBean
- - org.apache.activemq.artemis.core.management.impl.AbstractControl
  - - org.apache.activemq.artemis.core.management.impl.QueueControlImpl

All Implemented Interfaces:: DynamicMBean, MBeanRegistration, org.apache.activemq.artemis.api.core.management.QueueControl

public class QueueControlImpl
extends AbstractControl
implements org.apache.activemq.artemis.api.core.management.QueueControl

Field Summary

Fields
Modifier and Type Field and Description

static int FLUSH_LIMIT

Fields
Modifier and Type	Field and Description
`static int`	`FLUSH_LIMIT`

Constructor Summary

Constructors
Constructor and Description
`QueueControlImpl(Queue queue, String address, PostOffice postOffice, StorageManager storageManager, SecurityStore securityStore, HierarchicalRepository<AddressSettings> addressSettingsRepository)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`CompositeData[]`	`browse(String filterStr)`
`boolean`	`changeMessagePriority(long messageID, int newPriority)`
`int`	`changeMessagesPriority(String filterStr, int newPriority)`
`long`	`countMessages(String filterStr)`
`boolean`	`expireMessage(long messageID)`
`int`	`expireMessages(String filterStr)`
`protected MBeanAttributeInfo[]`	`fillMBeanAttributeInfo()`
`protected MBeanOperationInfo[]`	`fillMBeanOperationInfo()`
`void`	`flushExecutor()`
`String`	`getAddress()`
`int`	`getConsumerCount()`
`String`	`getDeadLetterAddress()`
`int`	`getDeliveringCount()`
`String`	`getExpiryAddress()`
`String`	`getFilter()`
`protected Map<String,Object>[]`	`getFirstMessage()`
`Long`	`getFirstMessageAge()`
`String`	`getFirstMessageAsJSON()`
`Long`	`getFirstMessageTimestamp()`
`long`	`getID()`
`long`	`getMessageCount()`
`long`	`getMessagesAcknowledged()`
`long`	`getMessagesAdded()`
`long`	`getMessagesExpired()`
`long`	`getMessagesKilled()`
`String`	`getName()`
`long`	`getScheduledCount()`
`boolean`	`isDurable()`
`boolean`	`isPaused()`
`boolean`	`isTemporary()`
`String`	`listConsumersAsJSON()`
`Map<String,Map<String,Object>[]>`	`listDeliveringMessages()`
`String`	`listDeliveringMessagesAsJSON()`
`String`	`listMessageCounter()`
`String`	`listMessageCounterAsHTML()`
`String`	`listMessageCounterHistory()`
`String`	`listMessageCounterHistoryAsHTML()`
`Map<String,Object>[]`	`listMessages(String filterStr)`
`String`	`listMessagesAsJSON(String filter)`
`Map<String,Object>[]`	`listScheduledMessages()`
`String`	`listScheduledMessagesAsJSON()`
`boolean`	`moveMessage(long messageID, String otherQueueName)`
`boolean`	`moveMessage(long messageID, String otherQueueName, boolean rejectDuplicates)`
`int`	`moveMessages(int flushLimit, String filterStr, String otherQueueName, boolean rejectDuplicates)`
`int`	`moveMessages(String filterStr, String otherQueueName)`
`int`	`moveMessages(String filterStr, String otherQueueName, boolean rejectDuplicates)`
`void`	`pause()`
`void`	`pause(boolean persist)`
`boolean`	`removeMessage(long messageID)`
`int`	`removeMessages(int flushLimit, String filterStr)`
`int`	`removeMessages(String filterStr)`
`void`	`resetMessageCounter()`
`void`	`resetMessagesAcknowledged()`
`void`	`resetMessagesAdded()`
`void`	`resetMessagesExpired()`
`void`	`resetMessagesKilled()`
`void`	`resume()`
`boolean`	`retryMessage(long messageID)`
`int`	`retryMessages()`
`String`	`sendMessage(Map<String,String> headers, int type, String body, String userID, boolean durable, String user, String password)`
`int`	`sendMessagesToDeadLetterAddress(String filterStr)`
`boolean`	`sendMessageToDeadLetterAddress(long messageID)`
`void`	`setMessageCounter(MessageCounter counter)`

Methods inherited from class org.apache.activemq.artemis.core.management.impl.AbstractControl
blockOnIO, clearIO, getMBeanInfo

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, postDeregister, postRegister, preDeregister, preRegister, setAttribute, setAttributes, setImplementation

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - FLUSH_LIMIT
```
public static final int FLUSH_LIMIT
```
    See Also:
    
    Constant Field Values
- Constructor Detail
  - QueueControlImpl
```
public QueueControlImpl(Queue queue,
                        String address,
                        PostOffice postOffice,
                        StorageManager storageManager,
                        SecurityStore securityStore,
                        HierarchicalRepository<AddressSettings> addressSettingsRepository)
                 throws Exception
```
    Throws:
    
    Exception
- Method Detail
  - setMessageCounter
```
public void setMessageCounter(MessageCounter counter)
```
  - getName
```
public String getName()
```
    Specified by:
    
    getName in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - getAddress
```
public String getAddress()
```
    Specified by:
    
    getAddress in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - getFilter
```
public String getFilter()
```
    Specified by:
    
    getFilter in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - isDurable
```
public boolean isDurable()
```
    Specified by:
    
    isDurable in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - isTemporary
```
public boolean isTemporary()
```
    Specified by:
    
    isTemporary in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - getMessageCount
```
public long getMessageCount()
```
    Specified by:
    
    getMessageCount in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - getConsumerCount
```
public int getConsumerCount()
```
    Specified by:
    
    getConsumerCount in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - getDeliveringCount
```
public int getDeliveringCount()
```
    Specified by:
    
    getDeliveringCount in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - getMessagesAdded
```
public long getMessagesAdded()
```
    Specified by:
    
    getMessagesAdded in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - getMessagesAcknowledged
```
public long getMessagesAcknowledged()
```
    Specified by:
    
    getMessagesAcknowledged in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - getMessagesExpired
```
public long getMessagesExpired()
```
    Specified by:
    
    getMessagesExpired in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - getMessagesKilled
```
public long getMessagesKilled()
```
    Specified by:
    
    getMessagesKilled in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - getID
```
public long getID()
```
    Specified by:
    
    getID in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - getScheduledCount
```
public long getScheduledCount()
```
    Specified by:
    
    getScheduledCount in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - getDeadLetterAddress
```
public String getDeadLetterAddress()
```
    Specified by:
    
    getDeadLetterAddress in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - getExpiryAddress
```
public String getExpiryAddress()
```
    Specified by:
    
    getExpiryAddress in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - listScheduledMessages
```
public Map<String,Object>[] listScheduledMessages()
                                           throws Exception
```
    Specified by:
    
    listScheduledMessages in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - listScheduledMessagesAsJSON
```
public String listScheduledMessagesAsJSON()
                                   throws Exception
```
    Specified by:
    
    listScheduledMessagesAsJSON in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - listDeliveringMessages
```
public Map<String,Map<String,Object>[]> listDeliveringMessages()
                                                        throws org.apache.activemq.artemis.api.core.ActiveMQException
```
    Specified by:
    
    listDeliveringMessages in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    org.apache.activemq.artemis.api.core.ActiveMQException
  - listDeliveringMessagesAsJSON
```
public String listDeliveringMessagesAsJSON()
                                    throws Exception
```
    Specified by:
    
    listDeliveringMessagesAsJSON in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - listMessages
```
public Map<String,Object>[] listMessages(String filterStr)
                                  throws Exception
```
    Specified by:
    
    listMessages in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - listMessagesAsJSON
```
public String listMessagesAsJSON(String filter)
                          throws Exception
```
    Specified by:
    
    listMessagesAsJSON in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - getFirstMessage
```
protected Map<String,Object>[] getFirstMessage()
                                        throws Exception
```
    Throws:
    
    Exception
  - getFirstMessageAsJSON
```
public String getFirstMessageAsJSON()
                             throws Exception
```
    Specified by:
    
    getFirstMessageAsJSON in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - getFirstMessageTimestamp
```
public Long getFirstMessageTimestamp()
                              throws Exception
```
    Specified by:
    
    getFirstMessageTimestamp in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - getFirstMessageAge
```
public Long getFirstMessageAge()
                        throws Exception
```
    Specified by:
    
    getFirstMessageAge in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - countMessages
```
public long countMessages(String filterStr)
                   throws Exception
```
    Specified by:
    
    countMessages in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - removeMessage
```
public boolean removeMessage(long messageID)
                      throws Exception
```
    Specified by:
    
    removeMessage in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - removeMessages
```
public int removeMessages(String filterStr)
                   throws Exception
```
    Specified by:
    
    removeMessages in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - removeMessages
```
public int removeMessages(int flushLimit,
                          String filterStr)
                   throws Exception
```
    Specified by:
    
    removeMessages in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - expireMessage
```
public boolean expireMessage(long messageID)
                      throws Exception
```
    Specified by:
    
    expireMessage in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - expireMessages
```
public int expireMessages(String filterStr)
                   throws Exception
```
    Specified by:
    
    expireMessages in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - retryMessage
```
public boolean retryMessage(long messageID)
                     throws Exception
```
    Specified by:
    
    retryMessage in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - retryMessages
```
public int retryMessages()
                  throws Exception
```
    Specified by:
    
    retryMessages in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - moveMessage
```
public boolean moveMessage(long messageID,
                           String otherQueueName)
                    throws Exception
```
    Specified by:
    
    moveMessage in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - moveMessage
```
public boolean moveMessage(long messageID,
                           String otherQueueName,
                           boolean rejectDuplicates)
                    throws Exception
```
    Specified by:
    
    moveMessage in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - moveMessages
```
public int moveMessages(String filterStr,
                        String otherQueueName)
                 throws Exception
```
    Specified by:
    
    moveMessages in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - moveMessages
```
public int moveMessages(int flushLimit,
                        String filterStr,
                        String otherQueueName,
                        boolean rejectDuplicates)
                 throws Exception
```
    Specified by:
    
    moveMessages in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - moveMessages
```
public int moveMessages(String filterStr,
                        String otherQueueName,
                        boolean rejectDuplicates)
                 throws Exception
```
    Specified by:
    
    moveMessages in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - sendMessagesToDeadLetterAddress
```
public int sendMessagesToDeadLetterAddress(String filterStr)
                                    throws Exception
```
    Specified by:
    
    sendMessagesToDeadLetterAddress in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - sendMessage
```
public String sendMessage(Map<String,String> headers,
                          int type,
                          String body,
                          String userID,
                          boolean durable,
                          String user,
                          String password)
                   throws Exception
```
    Specified by:
    
    sendMessage in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - sendMessageToDeadLetterAddress
```
public boolean sendMessageToDeadLetterAddress(long messageID)
                                       throws Exception
```
    Specified by:
    
    sendMessageToDeadLetterAddress in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - changeMessagesPriority
```
public int changeMessagesPriority(String filterStr,
                                  int newPriority)
                           throws Exception
```
    Specified by:
    
    changeMessagesPriority in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - changeMessagePriority
```
public boolean changeMessagePriority(long messageID,
                                     int newPriority)
                              throws Exception
```
    Specified by:
    
    changeMessagePriority in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - listMessageCounter
```
public String listMessageCounter()
```
    Specified by:
    
    listMessageCounter in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - resetMessageCounter
```
public void resetMessageCounter()
```
    Specified by:
    
    resetMessageCounter in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - listMessageCounterAsHTML
```
public String listMessageCounterAsHTML()
```
    Specified by:
    
    listMessageCounterAsHTML in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - listMessageCounterHistory
```
public String listMessageCounterHistory()
                                 throws Exception
```
    Specified by:
    
    listMessageCounterHistory in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - listMessageCounterHistoryAsHTML
```
public String listMessageCounterHistoryAsHTML()
```
    Specified by:
    
    listMessageCounterHistoryAsHTML in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - pause
```
public void pause()
```
    Specified by:
    
    pause in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - pause
```
public void pause(boolean persist)
```
    Specified by:
    
    pause in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - resume
```
public void resume()
```
    Specified by:
    
    resume in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - isPaused
```
public boolean isPaused()
                 throws Exception
```
    Specified by:
    
    isPaused in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - browse
```
public CompositeData[] browse(String filterStr)
                       throws Exception
```
    Specified by:
    
    browse in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - flushExecutor
```
public void flushExecutor()
```
    Specified by:
    
    flushExecutor in interface org.apache.activemq.artemis.api.core.management.QueueControl
  - listConsumersAsJSON
```
public String listConsumersAsJSON()
                           throws Exception
```
    Specified by:
    
    listConsumersAsJSON in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - fillMBeanOperationInfo
```
protected MBeanOperationInfo[] fillMBeanOperationInfo()
```
    Specified by:
    
    fillMBeanOperationInfo in class AbstractControl
  - fillMBeanAttributeInfo
```
protected MBeanAttributeInfo[] fillMBeanAttributeInfo()
```
    Specified by:
    
    fillMBeanAttributeInfo in class AbstractControl
  - resetMessagesAdded
```
public void resetMessagesAdded()
                        throws Exception
```
    Specified by:
    
    resetMessagesAdded in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - resetMessagesAcknowledged
```
public void resetMessagesAcknowledged()
                               throws Exception
```
    Specified by:
    
    resetMessagesAcknowledged in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - resetMessagesExpired
```
public void resetMessagesExpired()
                          throws Exception
```
    Specified by:
    
    resetMessagesExpired in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception
  - resetMessagesKilled
```
public void resetMessagesKilled()
                         throws Exception
```
    Specified by:
    
    resetMessagesKilled in interface org.apache.activemq.artemis.api.core.management.QueueControl
    
    Throws:
    
    Exception

Class QueueControlImpl

Field Summary

Constructor Summary

Method Summary

Methods inherited from class org.apache.activemq.artemis.core.management.impl.AbstractControl

Methods inherited from class javax.management.StandardMBean

Methods inherited from class java.lang.Object

Field Detail

FLUSH_LIMIT

Constructor Detail

QueueControlImpl

Method Detail

setMessageCounter

getName

getAddress

getFilter

isDurable

isTemporary

getMessageCount

getConsumerCount

getDeliveringCount

getMessagesAdded

getMessagesAcknowledged

getMessagesExpired

getMessagesKilled

getID

getScheduledCount

getDeadLetterAddress

getExpiryAddress

listScheduledMessages

listScheduledMessagesAsJSON

listDeliveringMessages

listDeliveringMessagesAsJSON

listMessages

listMessagesAsJSON

getFirstMessage

getFirstMessageAsJSON

getFirstMessageTimestamp

getFirstMessageAge

countMessages

removeMessage

removeMessages

removeMessages

expireMessage

expireMessages

retryMessage

retryMessages

moveMessage

moveMessage

moveMessages

moveMessages

moveMessages

sendMessagesToDeadLetterAddress

sendMessage

sendMessageToDeadLetterAddress

changeMessagesPriority

changeMessagePriority

listMessageCounter

resetMessageCounter

listMessageCounterAsHTML

listMessageCounterHistory

listMessageCounterHistoryAsHTML

pause

pause

resume

isPaused

browse

flushExecutor

listConsumersAsJSON

fillMBeanOperationInfo

fillMBeanAttributeInfo

resetMessagesAdded

resetMessagesAcknowledged

resetMessagesExpired

resetMessagesKilled