org.apache.qpid.server.queue
Class ConflationQueue

java.lang.Object
  extended by org.apache.qpid.server.queue.SimpleAMQQueue
      extended by org.apache.qpid.server.queue.ConflationQueue
All Implemented Interfaces:
Comparable<AMQQueue>, ConfiguredObject<QueueConfigType,QueueConfig>, QueueConfig, ExchangeReferrer, Managable, AMQQueue, BaseQueue, TransactionLogResource, Subscription.StateListener

public class ConflationQueue
extends SimpleAMQQueue


Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.qpid.server.queue.SimpleAMQQueue
SimpleAMQQueue.QueueEntryFilter
 
Nested classes/interfaces inherited from interface org.apache.qpid.server.queue.AMQQueue
AMQQueue.Context, AMQQueue.ExistingExclusiveSubscription, AMQQueue.ExistingSubscriptionPreventsExclusive, AMQQueue.Task
 
Nested classes/interfaces inherited from interface org.apache.qpid.server.queue.BaseQueue
BaseQueue.PostEnqueueAction
 
Field Summary
 
Fields inherited from class org.apache.qpid.server.queue.SimpleAMQQueue
_entries, _maximumMessageAge, _maximumMessageCount, _maximumMessageSize, _maximumQueueDepth, _minimumAlertRepeatGap, _subscriptionList, MAX_ASYNC_DELIVERIES
 
Constructor Summary
protected ConflationQueue(String name, boolean durable, String owner, boolean autoDelete, boolean exclusive, VirtualHost virtualHost, Map<String,Object> args, String conflationKey)
           
 
Method Summary
 String getConflationKey()
           
 
Methods inherited from class org.apache.qpid.server.queue.SimpleAMQQueue
addBinding, addQueueDeleteTask, advanceAllSubscriptions, checkCapacity, checkMessageStatus, checkSubscriptionsNotAheadOfDelivery, clearQueue, compareTo, configure, copyMessagesToAnotherQueue, decrementQueueCount, decrementUnackedMsgCount, delete, deleteMessageFromTop, deliverAsync, deliverAsync, dequeue, enqueue, enqueue, execute, flushSubscription, flushSubscription, getActiveConsumerCount, getAlternateExchange, getArguments, getAtomicQueueCount, getAtomicQueueSize, getBindingCount, getBindingCountHigh, getBindings, getByteTxnDequeues, getByteTxnEnqueues, getCapacity, getConfigStore, getConfigType, getConfiguration, getConsumerCount, getConsumerCountHigh, getCreateTime, getDeleteOnNoConsumers, getExclusiveOwningSession, getFlowResumeCapacity, getId, getLogSubject, getManagedObject, getMaximumMessageAge, getMaximumMessageCount, getMaximumMessageSize, getMaximumQueueDepth, getMessageCount, getMessageDequeueCount, getMessageOnTheQueue, getMessagesOnTheQueue, getMessagesOnTheQueue, getMessagesOnTheQueue, getMessagesOnTheQueue, getMessagesOnTheQueue, getMessagesRangeOnTheQueue, getMinimumAlertRepeatGap, getMsgTxnDequeues, getMsgTxnEnqueues, getName, getNameShortString, getNotificationChecks, getOldestMessageArrivalTime, getOldestQueueEntry, getOwner, getParent, getPersistentByteDequeues, getPersistentByteEnqueues, getPersistentMsgDequeues, getPersistentMsgEnqueues, getPrincipalHolder, getQueueDepth, getReceivedMessageCount, getResourceName, getTotalDequeueSize, getTotalEnqueueSize, getUnackedMessageCount, getUnackedMessageCountHigh, getUndeliveredMessageCount, getVirtualHost, hasExclusiveSubscriber, isAutoDelete, isDeleted, isDurable, isEmpty, isExclusive, isOverfull, isUnused, moveMessagesToAnotherQueue, purge, registerSubscription, removeBinding, removeMessagesFromQueue, removeQueueDeleteTask, requeue, requeue, resend, resetNotifications, setAlternateExchange, setCapacity, setDeleteOnNoConsumers, setExclusive, setExclusiveOwningSession, setFlowResumeCapacity, setMaximumMessageAge, setMaximumMessageCount, setMaximumMessageSize, setMaximumQueueDepth, setMinimumAlertRepeatGap, setNoLocal, setPrincipalHolder, stateChange, stop, toString, unregisterSubscription
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

ConflationQueue

protected ConflationQueue(String name,
                          boolean durable,
                          String owner,
                          boolean autoDelete,
                          boolean exclusive,
                          VirtualHost virtualHost,
                          Map<String,Object> args,
                          String conflationKey)
Method Detail

getConflationKey

public String getConflationKey()


Licensed to the Apache Software Foundation