QueueImpl (Red Hat JBoss Enterprise Application Platform 7.2.0.Beta public API)

java.lang.Object
- org.apache.activemq.artemis.core.server.impl.QueueImpl

All Implemented Interfaces:

Bindable, Queue

Direct Known Subclasses:

LastValueQueue
```
public class QueueImpl
extends Object
implements Queue
```
Implementation of a Queue
Completely non blocking between adding to queue and delivering to consumers.

Field Summary

Fields
Modifier and Type	Field and Description
`static int`	`CHECK_QUEUE_SIZE_PERIOD`
`static int`	`DEFAULT_FLUSH_LIMIT`
`protected AtomicInteger`	`deliveringCount`
`static int`	`DELIVERY_TIMEOUT` If The system gets slow for any reason, this is the maximum time a Delivery or or depage executor should be hanging on
`static int`	`MAX_DELIVERIES_IN_LOOP`
`static int`	`NUM_PRIORITIES`
`static int`	`REDISTRIBUTOR_BATCH_SIZE`

Constructor Summary

Constructors
Constructor and Description
`QueueImpl(long id, SimpleString address, SimpleString name, Filter filter, PageSubscription pageSubscription, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, Executor executor)`
`QueueImpl(long id, SimpleString address, SimpleString name, Filter filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, Executor executor)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`acknowledge(MessageReference ref)`
`void`	`acknowledge(MessageReference ref, AckReason reason)`
`void`	`acknowledge(Transaction tx, MessageReference ref)`
`void`	`acknowledge(Transaction tx, MessageReference ref, AckReason reason)`
`void`	`addConsumer(Consumer consumer)`
`void`	`addHead(List<MessageReference> refs, boolean scheduling)`
`void`	`addHead(MessageReference ref, boolean scheduling)`
`void`	`addRedistributor(long delay)`
`void`	`addTail(MessageReference ref)`
`void`	`addTail(MessageReference ref, boolean direct)`
`org.apache.activemq.artemis.core.server.impl.QueueImpl.QueueBrowserIterator`	`browserIterator()`
`void`	`cancel(MessageReference reference, long timeBase)`
`void`	`cancel(Transaction tx, MessageReference reference)`
`void`	`cancel(Transaction tx, MessageReference reference, boolean ignoreRedeliveryCheck)`
`void`	`cancelRedistributor()`
`boolean`	`changeReferencePriority(long messageID, byte newPriority)`
`int`	`changeReferencesPriority(Filter filter, byte newPriority)`
`boolean`	`checkRedelivery(MessageReference reference, long timeBase, boolean ignoreRedeliveryDelay)`
`void`	`close()`
`String`	`debug()`
`void`	`decDelivering()`
`void`	`decDelivering(int size)`
`int`	`deleteAllReferences()`
`int`	`deleteAllReferences(int flushLimit)`
`int`	`deleteMatchingReferences(Filter filter)`
`int`	`deleteMatchingReferences(int flushLimit, Filter filter1)`
`void`	`deleteQueue()`
`void`	`deleteQueue(boolean removeConsumers)`
`boolean`	`deleteReference(long messageID)`
`void`	`deliverAsync()`
`void`	`deliverNow()`
`void`	`deliverScheduledMessages()` cancels scheduled messages and send them to the head of the queue.
`void`	`destroyPaging()`
`boolean`	`equals(Object other)`
`void`	`expire(MessageReference ref)`
`boolean`	`expireReference(long messageID)`
`void`	`expireReferences()`
`int`	`expireReferences(Filter filter)` Expire all the references in the queue which matches the filter
`protected void`	`finalize()`
`boolean`	`flushExecutor()`
`void`	`forceDelivery()` This method will make sure that any pending message (including paged message) will be delivered
`SimpleString`	`getAddress()`
`int`	`getConsumerCount()`
`Set<Consumer>`	`getConsumers()`
`ReferenceCounter`	`getConsumersRefCount()`
`int`	`getDeliveringCount()`
`Map<String,List<MessageReference>>`	`getDeliveringMessages()` Return a Map consisting of consumer.toString and its messages Delivering message is a property of the consumer, this method will aggregate the results per Server's consumer object
`Executor`	`getExecutor()`
`SimpleString`	`getExpiryAddress()`
`Filter`	`getFilter()`
`List<SimpleString>`	`getGroupsUsed()` For testing only
`long`	`getID()`
`long`	`getMessageCount()`
`long`	`getMessagesAcknowledged()`
`long`	`getMessagesAdded()`
`long`	`getMessagesExpired()`
`long`	`getMessagesKilled()`
`SimpleString`	`getName()`
`int`	`getNumberOfReferences()` Used on testing only *
`PageSubscription`	`getPageSubscription()`
`float`	`getRate()`
`MessageReference`	`getReference(long id1)`
`SimpleString`	`getRoutingName()`
`int`	`getScheduledCount()`
`List<MessageReference>`	`getScheduledMessages()`
`SimpleString`	`getUniqueName()`
`SimpleString`	`getUser()`
`int`	`hashCode()`
`boolean`	`hasMatchingConsumer(ServerMessage message)`
`void`	`incrementMesssagesAdded()`
`boolean`	`isAutoCreated()`
`boolean`	`isDirectDeliver()`
`boolean`	`isDurable()`
`boolean`	`isExclusive()`
`boolean`	`isExpirationRedundant()`
`boolean`	`isInternalQueue()` We can't send stuff to DLQ on queues used on clustered-bridge-communication
`boolean`	`isPaused()`
`boolean`	`isPersistedPause()` if the pause was persisted
`boolean`	`isTemporary()`
`LinkedListIterator<MessageReference>`	`iterator()` It will iterate thorugh memory only (not paging)
`boolean`	`moveReference(long messageID, SimpleString toAddress)`
`boolean`	`moveReference(long messageID, SimpleString toAddress, boolean rejectDuplicate)`
`int`	`moveReferences(Filter filter, SimpleString toAddress)`
`int`	`moveReferences(int flushLimit, Filter filter, SimpleString toAddress, boolean rejectDuplicates)`
`int`	`moveReferencesBetweenSnFQueues(SimpleString queueSuffix)`
`void`	`pause()` Pauses the queue.
`void`	`pause(boolean persist)` Pauses the queue.
`void`	`postAcknowledge(MessageReference ref)`
`void`	`reacknowledge(Transaction tx, MessageReference ref)`
`protected void`	`refAdded(MessageReference ref)`
`void`	`referenceHandled()`
`protected void`	`refRemoved(MessageReference ref)`
`void`	`reload(MessageReference ref)`
`void`	`reloadPause(long recordID)`
`void`	`removeConsumer(Consumer consumer)`
`MessageReference`	`removeReferenceWithID(long id1)`
`void`	`resetAllIterators()`
`void`	`resetMessagesAcknowledged()`
`void`	`resetMessagesAdded()`
`void`	`resetMessagesExpired()`
`void`	`resetMessagesKilled()`
`void`	`resume()` Resumes the delivery of message for the queue.
`int`	`retryMessages(Filter filter)`
`void`	`route(ServerMessage message, RoutingContext context)`
`void`	`routeWithAck(ServerMessage message, RoutingContext context)`
`protected boolean`	`scheduleIfPossible(MessageReference ref)`
`int`	`sendMessagesToDeadLetterAddress(Filter filter)`
`boolean`	`sendMessageToDeadLetterAddress(long messageID)`
`void`	`sendToDeadLetterAddress(Transaction tx, MessageReference ref)`
`void`	`setConsumersRefCount(ReferenceCounter referenceCounter)` This will set a reference counter for every consumer present on the queue.
`void`	`setInternalQueue(boolean internalQueue)`
`String`	`toString()`
`void`	`unproposed(SimpleString groupID)`

Methods inherited from class java.lang.Object
clone, getClass, notify, notifyAll, wait, wait, wait

Field Detail
- REDISTRIBUTOR_BATCH_SIZE
```
public static final int REDISTRIBUTOR_BATCH_SIZE
```
  See Also:
  
  Constant Field Values
- NUM_PRIORITIES
```
public static final int NUM_PRIORITIES
```
  See Also:
  
  Constant Field Values
- MAX_DELIVERIES_IN_LOOP
```
public static final int MAX_DELIVERIES_IN_LOOP
```
  See Also:
  
  Constant Field Values
- CHECK_QUEUE_SIZE_PERIOD
```
public static final int CHECK_QUEUE_SIZE_PERIOD
```
  See Also:
  
  Constant Field Values
- DELIVERY_TIMEOUT
```
public static final int DELIVERY_TIMEOUT
```
  If The system gets slow for any reason, this is the maximum time a Delivery or or depage executor should be hanging on
  
  See Also:
  
  Constant Field Values
- DEFAULT_FLUSH_LIMIT
```
public static final int DEFAULT_FLUSH_LIMIT
```
  See Also:
  
  Constant Field Values
- deliveringCount
```
protected final AtomicInteger deliveringCount
```

Constructor Detail

QueueImpl

public QueueImpl(long id,
                 SimpleString address,
                 SimpleString name,
                 Filter filter,
                 SimpleString user,
                 boolean durable,
                 boolean temporary,
                 boolean autoCreated,
                 ScheduledExecutorService scheduledExecutor,
                 PostOffice postOffice,
                 StorageManager storageManager,
                 HierarchicalRepository<AddressSettings> addressSettingsRepository,
                 Executor executor)

QueueImpl

public QueueImpl(long id,
                 SimpleString address,
                 SimpleString name,
                 Filter filter,
                 PageSubscription pageSubscription,
                 SimpleString user,
                 boolean durable,
                 boolean temporary,
                 boolean autoCreated,
                 ScheduledExecutorService scheduledExecutor,
                 PostOffice postOffice,
                 StorageManager storageManager,
                 HierarchicalRepository<AddressSettings> addressSettingsRepository,
                 Executor executor)

Method Detail
- getGroupsUsed
```
public List<SimpleString> getGroupsUsed()
```
  For testing only
- debug
```
public String debug()
```
- getRoutingName
```
public SimpleString getRoutingName()
```
- getUniqueName
```
public SimpleString getUniqueName()
```
- getUser
```
public SimpleString getUser()
```
  Specified by:
  
  getUser in interface Queue
  
  Returns:
  
  the user who created this queue
- isExclusive
```
public boolean isExclusive()
```
- route
```
public void route(ServerMessage message,
                  RoutingContext context)
           throws Exception
```
  Specified by:
  
  route in interface Bindable
  
  Throws:
  
  Exception
- routeWithAck
```
public void routeWithAck(ServerMessage message,
                         RoutingContext context)
```
  Specified by:
  
  routeWithAck in interface Bindable
- setConsumersRefCount
```
public void setConsumersRefCount(ReferenceCounter referenceCounter)
```
  Description copied from interface: Queue
  
  This will set a reference counter for every consumer present on the queue. The ReferenceCounter will know what to do when the counter became zeroed. This is used to control what to do with temporary queues, especially on shared subscriptions where the queue needs to be deleted when all the consumers are closed.
  
  Specified by:
  
  setConsumersRefCount in interface Queue
- getConsumersRefCount
```
public ReferenceCounter getConsumersRefCount()
```
  Specified by:
  
  getConsumersRefCount in interface Queue
- isDurable
```
public boolean isDurable()
```
  Specified by:
  
  isDurable in interface Queue
- isTemporary
```
public boolean isTemporary()
```
  Specified by:
  
  isTemporary in interface Queue
- isAutoCreated
```
public boolean isAutoCreated()
```
  Specified by:
  
  isAutoCreated in interface Queue
- getName
```
public SimpleString getName()
```
  Specified by:
  
  getName in interface Queue
- getAddress
```
public SimpleString getAddress()
```
  Specified by:
  
  getAddress in interface Queue
- getID
```
public long getID()
```
  Specified by:
  
  getID in interface Queue
- getPageSubscription
```
public PageSubscription getPageSubscription()
```
  Specified by:
  
  getPageSubscription in interface Queue
- getFilter
```
public Filter getFilter()
```
  Specified by:
  
  getFilter in interface Queue
- unproposed
```
public void unproposed(SimpleString groupID)
```
  Specified by:
  
  unproposed in interface Queue
- addHead
```
public void addHead(MessageReference ref,
                    boolean scheduling)
```
  Specified by:
  
  addHead in interface Queue
- addHead
```
public void addHead(List<MessageReference> refs,
                    boolean scheduling)
```
  Specified by:
  
  addHead in interface Queue
- reload
```
public void reload(MessageReference ref)
```
  Specified by:
  
  reload in interface Queue
- addTail
```
public void addTail(MessageReference ref)
```
  Specified by:
  
  addTail in interface Queue
- addTail
```
public void addTail(MessageReference ref,
                    boolean direct)
```
  Specified by:
  
  addTail in interface Queue
- scheduleIfPossible
```
protected boolean scheduleIfPossible(MessageReference ref)
```
- forceDelivery
```
public void forceDelivery()
```
  Description copied from interface: Queue
  
  This method will make sure that any pending message (including paged message) will be delivered
  
  Specified by:
  
  forceDelivery in interface Queue
- deliverAsync
```
public void deliverAsync()
```
  Specified by:
  
  deliverAsync in interface Queue
- close
```
public void close()
           throws Exception
```
  Specified by:
  
  close in interface Queue
  
  Throws:
  
  Exception
- getExecutor
```
public Executor getExecutor()
```
  Specified by:
  
  getExecutor in interface Queue
- deliverNow
```
public void deliverNow()
```
- flushExecutor
```
public boolean flushExecutor()
```
  Specified by:
  
  flushExecutor in interface Queue
- addConsumer
```
public void addConsumer(Consumer consumer)
                 throws Exception
```
  Specified by:
  
  addConsumer in interface Queue
  
  Throws:
  
  Exception
- removeConsumer
```
public void removeConsumer(Consumer consumer)
```
  Specified by:
  
  removeConsumer in interface Queue
- addRedistributor
```
public void addRedistributor(long delay)
```
  Specified by:
  
  addRedistributor in interface Queue
- cancelRedistributor
```
public void cancelRedistributor()
                         throws Exception
```
  Specified by:
  
  cancelRedistributor in interface Queue
  
  Throws:
  
  Exception
- finalize
```
protected void finalize()
                 throws Throwable
```
  Overrides:
  
  finalize in class Object
  
  Throws:
  
  Throwable
- getConsumerCount
```
public int getConsumerCount()
```
  Specified by:
  
  getConsumerCount in interface Queue
- getConsumers
```
public Set<Consumer> getConsumers()
```
  Specified by:
  
  getConsumers in interface Queue
- hasMatchingConsumer
```
public boolean hasMatchingConsumer(ServerMessage message)
```
  Specified by:
  
  hasMatchingConsumer in interface Queue
- iterator
```
public LinkedListIterator<MessageReference> iterator()
```
  Description copied from interface: Queue
  
  It will iterate thorugh memory only (not paging)
  
  Specified by:
  
  iterator in interface Queue
  
  Returns:
- browserIterator
```
public org.apache.activemq.artemis.core.server.impl.QueueImpl.QueueBrowserIterator browserIterator()
```
  Specified by:
  
  browserIterator in interface Queue
- removeReferenceWithID
```
public MessageReference removeReferenceWithID(long id1)
                                       throws Exception
```
  Specified by:
  
  removeReferenceWithID in interface Queue
  
  Throws:
  
  Exception
- getReference
```
public MessageReference getReference(long id1)
                              throws ActiveMQException
```
  Specified by:
  
  getReference in interface Queue
  
  Throws:
  
  ActiveMQException
- getMessageCount
```
public long getMessageCount()
```
  Specified by:
  
  getMessageCount in interface Queue
- getScheduledCount
```
public int getScheduledCount()
```
  Specified by:
  
  getScheduledCount in interface Queue
- getScheduledMessages
```
public List<MessageReference> getScheduledMessages()
```
  Specified by:
  
  getScheduledMessages in interface Queue
- getDeliveringMessages
```
public Map<String,List<MessageReference>> getDeliveringMessages()
```
  Description copied from interface: Queue
  
  Return a Map consisting of consumer.toString and its messages Delivering message is a property of the consumer, this method will aggregate the results per Server's consumer object
  
  Specified by:
  
  getDeliveringMessages in interface Queue
  
  Returns:
- getDeliveringCount
```
public int getDeliveringCount()
```
  Specified by:
  
  getDeliveringCount in interface Queue
- acknowledge
```
public void acknowledge(MessageReference ref)
                 throws Exception
```
  Specified by:
  
  acknowledge in interface Queue
  
  Throws:
  
  Exception
- acknowledge
```
public void acknowledge(MessageReference ref,
                        AckReason reason)
                 throws Exception
```
  Specified by:
  
  acknowledge in interface Queue
  
  Throws:
  
  Exception
- acknowledge
```
public void acknowledge(Transaction tx,
                        MessageReference ref)
                 throws Exception
```
  Specified by:
  
  acknowledge in interface Queue
  
  Throws:
  
  Exception
- acknowledge
```
public void acknowledge(Transaction tx,
                        MessageReference ref,
                        AckReason reason)
                 throws Exception
```
  Specified by:
  
  acknowledge in interface Queue
  
  Throws:
  
  Exception
- reacknowledge
```
public void reacknowledge(Transaction tx,
                          MessageReference ref)
                   throws Exception
```
  Specified by:
  
  reacknowledge in interface Queue
  
  Throws:
  
  Exception
- cancel
```
public void cancel(Transaction tx,
                   MessageReference reference)
```
  Specified by:
  
  cancel in interface Queue
- cancel
```
public void cancel(Transaction tx,
                   MessageReference reference,
                   boolean ignoreRedeliveryCheck)
```
  Specified by:
  
  cancel in interface Queue
- cancel
```
public void cancel(MessageReference reference,
                   long timeBase)
            throws Exception
```
  Specified by:
  
  cancel in interface Queue
  
  Throws:
  
  Exception
- expire
```
public void expire(MessageReference ref)
            throws Exception
```
  Specified by:
  
  expire in interface Queue
  
  Throws:
  
  Exception
- getExpiryAddress
```
public SimpleString getExpiryAddress()
```
  Specified by:
  
  getExpiryAddress in interface Queue
- referenceHandled
```
public void referenceHandled()
```
  Specified by:
  
  referenceHandled in interface Queue
- incrementMesssagesAdded
```
public void incrementMesssagesAdded()
```
  Specified by:
  
  incrementMesssagesAdded in interface Queue
- deliverScheduledMessages
```
public void deliverScheduledMessages()
                              throws ActiveMQException
```
  Description copied from interface: Queue
  
  cancels scheduled messages and send them to the head of the queue.
  
  Specified by:
  
  deliverScheduledMessages in interface Queue
  
  Throws:
  
  ActiveMQException
- getMessagesAdded
```
public long getMessagesAdded()
```
  Specified by:
  
  getMessagesAdded in interface Queue
- getMessagesAcknowledged
```
public long getMessagesAcknowledged()
```
  Specified by:
  
  getMessagesAcknowledged in interface Queue
- getMessagesExpired
```
public long getMessagesExpired()
```
  Specified by:
  
  getMessagesExpired in interface Queue
- getMessagesKilled
```
public long getMessagesKilled()
```
  Specified by:
  
  getMessagesKilled in interface Queue
- deleteAllReferences
```
public int deleteAllReferences()
                        throws Exception
```
  Specified by:
  
  deleteAllReferences in interface Queue
  
  Throws:
  
  Exception
- deleteAllReferences
```
public int deleteAllReferences(int flushLimit)
                        throws Exception
```
  Specified by:
  
  deleteAllReferences in interface Queue
  
  Throws:
  
  Exception
- deleteMatchingReferences
```
public int deleteMatchingReferences(Filter filter)
                             throws Exception
```
  Specified by:
  
  deleteMatchingReferences in interface Queue
  
  Throws:
  
  Exception
- deleteMatchingReferences
```
public int deleteMatchingReferences(int flushLimit,
                                    Filter filter1)
                             throws Exception
```
  Specified by:
  
  deleteMatchingReferences in interface Queue
  
  Throws:
  
  Exception
- destroyPaging
```
public void destroyPaging()
                   throws Exception
```
  Specified by:
  
  destroyPaging in interface Queue
  
  Throws:
  
  Exception
- deleteReference
```
public boolean deleteReference(long messageID)
                        throws Exception
```
  Specified by:
  
  deleteReference in interface Queue
  
  Throws:
  
  Exception
- deleteQueue
```
public void deleteQueue()
                 throws Exception
```
  Specified by:
  
  deleteQueue in interface Queue
  
  Throws:
  
  Exception
- deleteQueue
```
public void deleteQueue(boolean removeConsumers)
                 throws Exception
```
  Specified by:
  
  deleteQueue in interface Queue
  
  Throws:
  
  Exception
- expireReference
```
public boolean expireReference(long messageID)
                        throws Exception
```
  Specified by:
  
  expireReference in interface Queue
  
  Throws:
  
  Exception
- expireReferences
```
public int expireReferences(Filter filter)
                     throws Exception
```
  Description copied from interface: Queue
  
  Expire all the references in the queue which matches the filter
  
  Specified by:
  
  expireReferences in interface Queue
  
  Throws:
  
  Exception
- expireReferences
```
public void expireReferences()
```
  Specified by:
  
  expireReferences in interface Queue
- isExpirationRedundant
```
public boolean isExpirationRedundant()
```
- sendMessageToDeadLetterAddress
```
public boolean sendMessageToDeadLetterAddress(long messageID)
                                       throws Exception
```
  Specified by:
  
  sendMessageToDeadLetterAddress in interface Queue
  
  Throws:
  
  Exception
- sendMessagesToDeadLetterAddress
```
public int sendMessagesToDeadLetterAddress(Filter filter)
                                    throws Exception
```
  Specified by:
  
  sendMessagesToDeadLetterAddress in interface Queue
  
  Throws:
  
  Exception
- moveReference
```
public boolean moveReference(long messageID,
                             SimpleString toAddress)
                      throws Exception
```
  Specified by:
  
  moveReference in interface Queue
  
  Throws:
  
  Exception
- moveReference
```
public boolean moveReference(long messageID,
                             SimpleString toAddress,
                             boolean rejectDuplicate)
                      throws Exception
```
  Specified by:
  
  moveReference in interface Queue
  
  Throws:
  
  Exception
- moveReferences
```
public int moveReferences(Filter filter,
                          SimpleString toAddress)
                   throws Exception
```
  Specified by:
  
  moveReferences in interface Queue
  
  Throws:
  
  Exception
- moveReferences
```
public int moveReferences(int flushLimit,
                          Filter filter,
                          SimpleString toAddress,
                          boolean rejectDuplicates)
                   throws Exception
```
  Specified by:
  
  moveReferences in interface Queue
  
  Throws:
  
  Exception
- moveReferencesBetweenSnFQueues
```
public int moveReferencesBetweenSnFQueues(SimpleString queueSuffix)
                                   throws Exception
```
  Throws:
  
  Exception
- retryMessages
```
public int retryMessages(Filter filter)
                  throws Exception
```
  Specified by:
  
  retryMessages in interface Queue
  
  Throws:
  
  Exception
- changeReferencePriority
```
public boolean changeReferencePriority(long messageID,
                                       byte newPriority)
                                throws Exception
```
  Specified by:
  
  changeReferencePriority in interface Queue
  
  Throws:
  
  Exception
- changeReferencesPriority
```
public int changeReferencesPriority(Filter filter,
                                    byte newPriority)
                             throws Exception
```
  Specified by:
  
  changeReferencesPriority in interface Queue
  
  Throws:
  
  Exception
- resetAllIterators
```
public void resetAllIterators()
```
  Specified by:
  
  resetAllIterators in interface Queue
- pause
```
public void pause()
```
  Description copied from interface: Queue
  
  Pauses the queue. It will receive messages but won't give them to the consumers until resumed. If a queue is paused, pausing it again will only throw a warning. To check if a queue is paused, invoke isPaused()
  
  Specified by:
  
  pause in interface Queue
- reloadPause
```
public void reloadPause(long recordID)
```
  Specified by:
  
  reloadPause in interface Queue
- pause
```
public void pause(boolean persist)
```
  Description copied from interface: Queue
  
  Pauses the queue. It will receive messages but won't give them to the consumers until resumed. If a queue is paused, pausing it again will only throw a warning. To check if a queue is paused, invoke isPaused()
  
  Specified by:
  
  pause in interface Queue
- resume
```
public void resume()
```
  Description copied from interface: Queue
  
  Resumes the delivery of message for the queue. If a queue is resumed, resuming it again will only throw a warning. To check if a queue is resumed, invoke isPaused()
  
  Specified by:
  
  resume in interface Queue
- isPaused
```
public boolean isPaused()
```
  Specified by:
  
  isPaused in interface Queue
  
  Returns:
  
  true if paused, false otherwise.
- isPersistedPause
```
public boolean isPersistedPause()
```
  Description copied from interface: Queue
  
  if the pause was persisted
  
  Specified by:
  
  isPersistedPause in interface Queue
  
  Returns:
- isDirectDeliver
```
public boolean isDirectDeliver()
```
  Specified by:
  
  isDirectDeliver in interface Queue
- isInternalQueue
```
public boolean isInternalQueue()
```
  Description copied from interface: Queue
  
  We can't send stuff to DLQ on queues used on clustered-bridge-communication
  
  Specified by:
  
  isInternalQueue in interface Queue
  
  Returns:
  
  the internalQueue
- setInternalQueue
```
public void setInternalQueue(boolean internalQueue)
```
  Specified by:
  
  setInternalQueue in interface Queue
  
  Parameters:
  
  internalQueue - the internalQueue to set
- equals
```
public boolean equals(Object other)
```
  Overrides:
  
  equals in class Object
- hashCode
```
public int hashCode()
```
  Overrides:
  
  hashCode in class Object
- toString
```
public String toString()
```
  Overrides:
  
  toString in class Object
- refRemoved
```
protected void refRemoved(MessageReference ref)
```
- refAdded
```
protected void refAdded(MessageReference ref)
```
- checkRedelivery
```
public boolean checkRedelivery(MessageReference reference,
                               long timeBase,
                               boolean ignoreRedeliveryDelay)
                        throws Exception
```
  Specified by:
  
  checkRedelivery in interface Queue
  
  Throws:
  
  Exception
- getNumberOfReferences
```
public int getNumberOfReferences()
```
  Used on testing only *
- sendToDeadLetterAddress
```
public void sendToDeadLetterAddress(Transaction tx,
                                    MessageReference ref)
                             throws Exception
```
  Specified by:
  
  sendToDeadLetterAddress in interface Queue
  
  Throws:
  
  Exception
- postAcknowledge
```
public void postAcknowledge(MessageReference ref)
```
  Specified by:
  
  postAcknowledge in interface Queue
- resetMessagesAdded
```
public void resetMessagesAdded()
```
  Specified by:
  
  resetMessagesAdded in interface Queue
- resetMessagesAcknowledged
```
public void resetMessagesAcknowledged()
```
  Specified by:
  
  resetMessagesAcknowledged in interface Queue
- resetMessagesExpired
```
public void resetMessagesExpired()
```
  Specified by:
  
  resetMessagesExpired in interface Queue
- resetMessagesKilled
```
public void resetMessagesKilled()
```
  Specified by:
  
  resetMessagesKilled in interface Queue
- getRate
```
public float getRate()
```
  Specified by:
  
  getRate in interface Queue
- decDelivering
```
public void decDelivering()
```
- decDelivering
```
public void decDelivering(int size)
```
  Specified by:
  
  decDelivering in interface Queue

Class QueueImpl

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

REDISTRIBUTOR_BATCH_SIZE

NUM_PRIORITIES

MAX_DELIVERIES_IN_LOOP

CHECK_QUEUE_SIZE_PERIOD

DELIVERY_TIMEOUT

DEFAULT_FLUSH_LIMIT

deliveringCount

Constructor Detail

QueueImpl

QueueImpl

Method Detail

getGroupsUsed

debug

getRoutingName

getUniqueName

getUser

isExclusive

route

routeWithAck

setConsumersRefCount

getConsumersRefCount

isDurable

isTemporary

isAutoCreated

getName

getAddress

getID

getPageSubscription

getFilter

unproposed

addHead

addHead

reload

addTail

addTail

scheduleIfPossible

forceDelivery

deliverAsync

close

getExecutor

deliverNow

flushExecutor

addConsumer

removeConsumer

addRedistributor

cancelRedistributor

finalize

getConsumerCount

getConsumers

hasMatchingConsumer

iterator

browserIterator

removeReferenceWithID

getReference

getMessageCount

getScheduledCount

getScheduledMessages

getDeliveringMessages

getDeliveringCount

acknowledge

acknowledge

acknowledge

acknowledge

reacknowledge

cancel

cancel

cancel

expire

getExpiryAddress

referenceHandled

incrementMesssagesAdded

deliverScheduledMessages

getMessagesAdded

getMessagesAcknowledged