Class QueueQueryImpl
java.lang.Object
org.apache.activemq.artemis.core.client.impl.QueueQueryImpl
- All Implemented Interfaces:
ClientSession.QueueQuery
-
Constructor Summary
ConstructorsConstructorDescriptionQueueQueryImpl(boolean durable, boolean temporary, int consumerCount, long messageCount, SimpleString filterString, SimpleString address, SimpleString name, boolean exists) QueueQueryImpl(boolean durable, boolean temporary, int consumerCount, long messageCount, SimpleString filterString, SimpleString address, SimpleString name, boolean exists, boolean autoCreateQueues) QueueQueryImpl(boolean durable, boolean temporary, int consumerCount, long messageCount, SimpleString filterString, SimpleString address, SimpleString name, boolean exists, boolean autoCreateQueues, int maxConsumers, boolean autoCreated, boolean purgeOnNoConsumers, RoutingType routingType) QueueQueryImpl(boolean durable, boolean temporary, int consumerCount, long messageCount, SimpleString filterString, SimpleString address, SimpleString name, boolean exists, boolean autoCreateQueues, int maxConsumers, boolean autoCreated, boolean purgeOnNoConsumers, RoutingType routingType, Boolean exclusive, Boolean groupRebalance, Boolean groupRebalancePauseDispatch, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, Integer defaultConsumerWindowSize, Long ringSize, Boolean enabled, Boolean configurationManaged) QueueQueryImpl(boolean durable, boolean temporary, int consumerCount, long messageCount, SimpleString filterString, SimpleString address, SimpleString name, boolean exists, boolean autoCreateQueues, int maxConsumers, boolean autoCreated, boolean purgeOnNoConsumers, RoutingType routingType, Boolean exclusive, Boolean lastValue, Integer defaultConsumerWindowSize) QueueQueryImpl(boolean durable, boolean temporary, int consumerCount, long messageCount, SimpleString filterString, SimpleString address, SimpleString name, boolean exists, boolean autoCreateQueues, int maxConsumers, boolean autoCreated, boolean purgeOnNoConsumers, RoutingType routingType, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, Integer defaultConsumerWindowSize) -
Method Summary
Modifier and TypeMethodDescriptionReturns the address that the queue is bound to.intReturns the number of consumers attached to the queue.Returns the queue's filter string (ornullif the queue has no filter).intlongReturns the number of messages in the queue.getName()Return the name of the queuebooleanbooleanReturnstrueif auto-creation for this queue is enabled and if the queue queried is a JMS queue,falseelse.booleanReturnstrueif the queue is durable,falseelse.booleanisExists()Returnstrueif the queue exists,falseelse.booleanbooleanReturnstrueif the queue is temporary,falseelse.
-
Constructor Details
-
QueueQueryImpl
public QueueQueryImpl(boolean durable, boolean temporary, int consumerCount, long messageCount, SimpleString filterString, SimpleString address, SimpleString name, boolean exists) -
QueueQueryImpl
public QueueQueryImpl(boolean durable, boolean temporary, int consumerCount, long messageCount, SimpleString filterString, SimpleString address, SimpleString name, boolean exists, boolean autoCreateQueues) -
QueueQueryImpl
public QueueQueryImpl(boolean durable, boolean temporary, int consumerCount, long messageCount, SimpleString filterString, SimpleString address, SimpleString name, boolean exists, boolean autoCreateQueues, int maxConsumers, boolean autoCreated, boolean purgeOnNoConsumers, RoutingType routingType) -
QueueQueryImpl
public QueueQueryImpl(boolean durable, boolean temporary, int consumerCount, long messageCount, SimpleString filterString, SimpleString address, SimpleString name, boolean exists, boolean autoCreateQueues, int maxConsumers, boolean autoCreated, boolean purgeOnNoConsumers, RoutingType routingType, Boolean exclusive, Boolean lastValue, Integer defaultConsumerWindowSize) -
QueueQueryImpl
public QueueQueryImpl(boolean durable, boolean temporary, int consumerCount, long messageCount, SimpleString filterString, SimpleString address, SimpleString name, boolean exists, boolean autoCreateQueues, int maxConsumers, boolean autoCreated, boolean purgeOnNoConsumers, RoutingType routingType, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, Integer defaultConsumerWindowSize) -
QueueQueryImpl
public QueueQueryImpl(boolean durable, boolean temporary, int consumerCount, long messageCount, SimpleString filterString, SimpleString address, SimpleString name, boolean exists, boolean autoCreateQueues, int maxConsumers, boolean autoCreated, boolean purgeOnNoConsumers, RoutingType routingType, Boolean exclusive, Boolean groupRebalance, Boolean groupRebalancePauseDispatch, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, Integer defaultConsumerWindowSize, Long ringSize, Boolean enabled, Boolean configurationManaged)
-
-
Method Details
-
getName
Description copied from interface:ClientSession.QueueQueryReturn the name of the queue- Specified by:
getNamein interfaceClientSession.QueueQuery
-
getAddress
Description copied from interface:ClientSession.QueueQueryReturns the address that the queue is bound to.- Specified by:
getAddressin interfaceClientSession.QueueQuery- Returns:
- the address that the queue is bound to
-
getConsumerCount
public int getConsumerCount()Description copied from interface:ClientSession.QueueQueryReturns the number of consumers attached to the queue.- Specified by:
getConsumerCountin interfaceClientSession.QueueQuery- Returns:
- the number of consumers attached to the queue
-
getFilterString
Description copied from interface:ClientSession.QueueQueryReturns the queue's filter string (ornullif the queue has no filter).- Specified by:
getFilterStringin interfaceClientSession.QueueQuery- Returns:
- the queue's filter string (or
nullif the queue has no filter)
-
getMessageCount
public long getMessageCount()Description copied from interface:ClientSession.QueueQueryReturns the number of messages in the queue.- Specified by:
getMessageCountin interfaceClientSession.QueueQuery- Returns:
- the number of messages in the queue
-
isDurable
public boolean isDurable()Description copied from interface:ClientSession.QueueQueryReturnstrueif the queue is durable,falseelse.- Specified by:
isDurablein interfaceClientSession.QueueQuery- Returns:
trueif the queue is durable,falseelse
-
isAutoCreateQueues
public boolean isAutoCreateQueues()Description copied from interface:ClientSession.QueueQueryReturnstrueif auto-creation for this queue is enabled and if the queue queried is a JMS queue,falseelse.- Specified by:
isAutoCreateQueuesin interfaceClientSession.QueueQuery- Returns:
trueif auto-creation for this queue is enabled and if the queue queried is a JMS queue,falseelse
-
isTemporary
public boolean isTemporary()Description copied from interface:ClientSession.QueueQueryReturnstrueif the queue is temporary,falseelse.- Specified by:
isTemporaryin interfaceClientSession.QueueQuery- Returns:
trueif the queue is temporary,falseelse
-
isExists
public boolean isExists()Description copied from interface:ClientSession.QueueQueryReturnstrueif the queue exists,falseelse.- Specified by:
isExistsin interfaceClientSession.QueueQuery- Returns:
trueif the queue exists,falseelse
-
getRoutingType
- Specified by:
getRoutingTypein interfaceClientSession.QueueQuery
-
getMaxConsumers
public int getMaxConsumers()- Specified by:
getMaxConsumersin interfaceClientSession.QueueQuery
-
isPurgeOnNoConsumers
public boolean isPurgeOnNoConsumers()- Specified by:
isPurgeOnNoConsumersin interfaceClientSession.QueueQuery
-
isAutoCreated
public boolean isAutoCreated()- Specified by:
isAutoCreatedin interfaceClientSession.QueueQuery
-
isExclusive
- Specified by:
isExclusivein interfaceClientSession.QueueQuery
-
isLastValue
- Specified by:
isLastValuein interfaceClientSession.QueueQuery
-
getLastValueKey
- Specified by:
getLastValueKeyin interfaceClientSession.QueueQuery
-
isNonDestructive
- Specified by:
isNonDestructivein interfaceClientSession.QueueQuery
-
getConsumersBeforeDispatch
- Specified by:
getConsumersBeforeDispatchin interfaceClientSession.QueueQuery
-
getDelayBeforeDispatch
- Specified by:
getDelayBeforeDispatchin interfaceClientSession.QueueQuery
-
getDefaultConsumerWindowSize
- Specified by:
getDefaultConsumerWindowSizein interfaceClientSession.QueueQuery
-
isGroupRebalance
- Specified by:
isGroupRebalancein interfaceClientSession.QueueQuery
-
isGroupRebalancePauseDispatch
- Specified by:
isGroupRebalancePauseDispatchin interfaceClientSession.QueueQuery
-
getGroupBuckets
- Specified by:
getGroupBucketsin interfaceClientSession.QueueQuery
-
getGroupFirstKey
- Specified by:
getGroupFirstKeyin interfaceClientSession.QueueQuery
-
isAutoDelete
- Specified by:
isAutoDeletein interfaceClientSession.QueueQuery
-
getAutoDeleteDelay
- Specified by:
getAutoDeleteDelayin interfaceClientSession.QueueQuery
-
getAutoDeleteMessageCount
- Specified by:
getAutoDeleteMessageCountin interfaceClientSession.QueueQuery
-
getRingSize
- Specified by:
getRingSizein interfaceClientSession.QueueQuery
-
isEnabled
- Specified by:
isEnabledin interfaceClientSession.QueueQuery
-
isConfigurationManaged
- Specified by:
isConfigurationManagedin interfaceClientSession.QueueQuery
-