public class QueueQueryImpl extends Object implements ClientSession.QueueQuery
Constructor and 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 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) |
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,
SimpleString groupFirstKey,
Boolean lastValue,
SimpleString lastValueKey,
Boolean nonDestructive,
Integer consumersBeforeDispatch,
Long delayBeforeDispatch,
Boolean autoDelete,
Long autoDeleteDelay,
Long autoDeleteMessageCount,
Integer defaultConsumerWindowSize) |
Modifier and Type | Method and 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
|
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 |
isDurable()
Returns
true if the queue is durable, false else. |
Boolean |
isExclusive() |
boolean |
isExists()
Returns
true if the queue exists, false else. |
Boolean |
isGroupRebalance() |
Boolean |
isLastValue() |
Boolean |
isNonDestructive() |
boolean |
isPurgeOnNoConsumers() |
boolean |
isTemporary()
Return
true if the queue is temporary, false else. |
public QueueQueryImpl(boolean durable, boolean temporary, int consumerCount, long messageCount, SimpleString filterString, SimpleString address, SimpleString name, boolean exists)
public QueueQueryImpl(boolean durable, boolean temporary, int consumerCount, long messageCount, SimpleString filterString, SimpleString address, SimpleString name, boolean exists, boolean autoCreateQueues)
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)
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)
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)
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, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, Integer defaultConsumerWindowSize)
public SimpleString getName()
ClientSession.QueueQuery
getName
in interface ClientSession.QueueQuery
public SimpleString getAddress()
ClientSession.QueueQuery
getAddress
in interface ClientSession.QueueQuery
public int getConsumerCount()
ClientSession.QueueQuery
getConsumerCount
in interface ClientSession.QueueQuery
public SimpleString getFilterString()
ClientSession.QueueQuery
null
if the queue has no filter).getFilterString
in interface ClientSession.QueueQuery
public long getMessageCount()
ClientSession.QueueQuery
getMessageCount
in interface ClientSession.QueueQuery
public boolean isDurable()
ClientSession.QueueQuery
true
if the queue is durable, false
else.isDurable
in interface ClientSession.QueueQuery
public boolean isAutoCreateQueues()
ClientSession.QueueQuery
true
if auto-creation for this queue is enabled and if the queue queried is a JMS queue,
false
else.isAutoCreateQueues
in interface ClientSession.QueueQuery
public boolean isTemporary()
ClientSession.QueueQuery
true
if the queue is temporary, false
else.isTemporary
in interface ClientSession.QueueQuery
public boolean isExists()
ClientSession.QueueQuery
true
if the queue exists, false
else.isExists
in interface ClientSession.QueueQuery
public RoutingType getRoutingType()
getRoutingType
in interface ClientSession.QueueQuery
public int getMaxConsumers()
getMaxConsumers
in interface ClientSession.QueueQuery
public boolean isPurgeOnNoConsumers()
isPurgeOnNoConsumers
in interface ClientSession.QueueQuery
public boolean isAutoCreated()
isAutoCreated
in interface ClientSession.QueueQuery
public Boolean isExclusive()
isExclusive
in interface ClientSession.QueueQuery
public Boolean isLastValue()
isLastValue
in interface ClientSession.QueueQuery
public SimpleString getLastValueKey()
getLastValueKey
in interface ClientSession.QueueQuery
public Boolean isNonDestructive()
isNonDestructive
in interface ClientSession.QueueQuery
public Integer getConsumersBeforeDispatch()
getConsumersBeforeDispatch
in interface ClientSession.QueueQuery
public Long getDelayBeforeDispatch()
getDelayBeforeDispatch
in interface ClientSession.QueueQuery
public Integer getDefaultConsumerWindowSize()
getDefaultConsumerWindowSize
in interface ClientSession.QueueQuery
public Boolean isGroupRebalance()
isGroupRebalance
in interface ClientSession.QueueQuery
public Integer getGroupBuckets()
getGroupBuckets
in interface ClientSession.QueueQuery
public SimpleString getGroupFirstKey()
getGroupFirstKey
in interface ClientSession.QueueQuery
public Boolean isAutoDelete()
isAutoDelete
in interface ClientSession.QueueQuery
public Long getAutoDeleteDelay()
getAutoDeleteDelay
in interface ClientSession.QueueQuery
public Long getAutoDeleteMessageCount()
getAutoDeleteMessageCount
in interface ClientSession.QueueQuery
Copyright © 2019 JBoss by Red Hat. All rights reserved.