Package org.apache.activemq.artemis.core.client.impl

Class QueueQueryImpl

java.lang.Object

org.apache.activemq.artemis.core.client.impl.QueueQueryImpl

All Implemented Interfaces:

ClientSession.QueueQuery

public class QueueQueryImpl
extends Object
implements ClientSession.QueueQuery

Constructor Summary

Constructors

Constructor	Description
QueueQueryImpl(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 Type	Method	Description
SimpleString	getAddress()	Returns the address that the queue is bound to.
Long	getAutoDeleteDelay()
Long	getAutoDeleteMessageCount()
int	getConsumerCount()	Returns the number of consumers attached to the queue.
Integer	getConsumersBeforeDispatch()
Integer	getDefaultConsumerWindowSize()
Long	getDelayBeforeDispatch()
SimpleString	getFilterString()	Returns the queue's filter string (or null if the queue has no filter).
Integer	getGroupBuckets()
SimpleString	getGroupFirstKey()
SimpleString	getLastValueKey()
int	getMaxConsumers()
long	getMessageCount()	Returns the number of messages in the queue.
SimpleString	getName()	Return the name of the queue
Long	getRingSize()
RoutingType	getRoutingType()
boolean	isAutoCreated()
boolean	isAutoCreateQueues()	Returns true if auto-creation for this queue is enabled and if the queue queried is a JMS queue, false else.
Boolean	isAutoDelete()
Boolean	isConfigurationManaged()
boolean	isDurable()	Returns true if the queue is durable, false else.
Boolean	isEnabled()
Boolean	isExclusive()
boolean	isExists()	Returns true if the queue exists, false else.
Boolean	isGroupRebalance()
Boolean	isGroupRebalancePauseDispatch()
Boolean	isLastValue()
Boolean	isNonDestructive()
boolean	isPurgeOnNoConsumers()
boolean	isTemporary()	Returns true if the queue is temporary, false else.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

public SimpleString getName()

Description copied from interface: ClientSession.QueueQuery

Return the name of the queue

Specified by:

getName in interface ClientSession.QueueQuery

getAddress

public SimpleString getAddress()

Description copied from interface: ClientSession.QueueQuery

Returns the address that the queue is bound to.

Specified by:

getAddress in interface ClientSession.QueueQuery

Returns:

the address that the queue is bound to

getConsumerCount

public int getConsumerCount()

Description copied from interface: ClientSession.QueueQuery

Returns the number of consumers attached to the queue.

Specified by:

getConsumerCount in interface ClientSession.QueueQuery

Returns:

the number of consumers attached to the queue

getFilterString

public SimpleString getFilterString()

Description copied from interface: ClientSession.QueueQuery

Returns the queue's filter string (or null if the queue has no filter).

Specified by:

getFilterString in interface ClientSession.QueueQuery

Returns:

the queue's filter string (or null if the queue has no filter)

getMessageCount

public long getMessageCount()

Description copied from interface: ClientSession.QueueQuery

Returns the number of messages in the queue.

Specified by:

getMessageCount in interface ClientSession.QueueQuery

Returns:

the number of messages in the queue

isDurable

public boolean isDurable()

Description copied from interface: ClientSession.QueueQuery

Returns true if the queue is durable, false else.

Specified by:

isDurable in interface ClientSession.QueueQuery

Returns:

true if the queue is durable, false else

isAutoCreateQueues

public boolean isAutoCreateQueues()

Description copied from interface: ClientSession.QueueQuery

Returns true if auto-creation for this queue is enabled and if the queue queried is a JMS queue, false else.

Specified by:

isAutoCreateQueues in interface ClientSession.QueueQuery

Returns:

true if auto-creation for this queue is enabled and if the queue queried is a JMS queue, false else

isTemporary

public boolean isTemporary()

Description copied from interface: ClientSession.QueueQuery

Returns true if the queue is temporary, false else.

Specified by:

isTemporary in interface ClientSession.QueueQuery

Returns:

true if the queue is temporary, false else

isExists

public boolean isExists()

Description copied from interface: ClientSession.QueueQuery

Returns true if the queue exists, false else.

Specified by:

isExists in interface ClientSession.QueueQuery

Returns:

true if the queue exists, false else

getRoutingType

public RoutingType getRoutingType()

Specified by:

getRoutingType in interface ClientSession.QueueQuery

getMaxConsumers

public int getMaxConsumers()

Specified by:

getMaxConsumers in interface ClientSession.QueueQuery

isPurgeOnNoConsumers

public boolean isPurgeOnNoConsumers()

Specified by:

isPurgeOnNoConsumers in interface ClientSession.QueueQuery

isAutoCreated

public boolean isAutoCreated()

Specified by:

isAutoCreated in interface ClientSession.QueueQuery

isExclusive

public Boolean isExclusive()

Specified by:

isExclusive in interface ClientSession.QueueQuery

isLastValue

public Boolean isLastValue()

Specified by:

isLastValue in interface ClientSession.QueueQuery

getLastValueKey

public SimpleString getLastValueKey()

Specified by:

getLastValueKey in interface ClientSession.QueueQuery

isNonDestructive

public Boolean isNonDestructive()

Specified by:

isNonDestructive in interface ClientSession.QueueQuery

getConsumersBeforeDispatch

public Integer getConsumersBeforeDispatch()

Specified by:

getConsumersBeforeDispatch in interface ClientSession.QueueQuery

getDelayBeforeDispatch

public Long getDelayBeforeDispatch()

Specified by:

getDelayBeforeDispatch in interface ClientSession.QueueQuery

getDefaultConsumerWindowSize

public Integer getDefaultConsumerWindowSize()

Specified by:

getDefaultConsumerWindowSize in interface ClientSession.QueueQuery

isGroupRebalance

public Boolean isGroupRebalance()

Specified by:

isGroupRebalance in interface ClientSession.QueueQuery

isGroupRebalancePauseDispatch

public Boolean isGroupRebalancePauseDispatch()

Specified by:

isGroupRebalancePauseDispatch in interface ClientSession.QueueQuery

getGroupBuckets

public Integer getGroupBuckets()

Specified by:

getGroupBuckets in interface ClientSession.QueueQuery

getGroupFirstKey

public SimpleString getGroupFirstKey()

Specified by:

getGroupFirstKey in interface ClientSession.QueueQuery

isAutoDelete

public Boolean isAutoDelete()

Specified by:

isAutoDelete in interface ClientSession.QueueQuery

getAutoDeleteDelay

public Long getAutoDeleteDelay()

Specified by:

getAutoDeleteDelay in interface ClientSession.QueueQuery

getAutoDeleteMessageCount

public Long getAutoDeleteMessageCount()

Specified by:

getAutoDeleteMessageCount in interface ClientSession.QueueQuery

getRingSize

public Long getRingSize()

Specified by:

getRingSize in interface ClientSession.QueueQuery

isEnabled

public Boolean isEnabled()

Specified by:

isEnabled in interface ClientSession.QueueQuery

isConfigurationManaged

public Boolean isConfigurationManaged()

Specified by:

isConfigurationManaged in interface ClientSession.QueueQuery