org.apache.qpid.server.queue
Class AMQPriorityQueue

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

public class AMQPriorityQueue
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 AMQPriorityQueue(org.apache.qpid.framing.AMQShortString name, boolean durable, org.apache.qpid.framing.AMQShortString owner, boolean autoDelete, boolean exclusive, VirtualHost virtualHost, int priorities, Map<String,Object> arguments)
           
  AMQPriorityQueue(String queueName, boolean durable, String owner, boolean autoDelete, boolean exclusive, VirtualHost virtualHost, int priorities, Map<String,Object> arguments)
           
 
Method Summary
protected  void checkSubscriptionsNotAheadOfDelivery(QueueEntry entry)
           
 int getPriorities()
           
 
Methods inherited from class org.apache.qpid.server.queue.SimpleAMQQueue
addBinding, addQueueDeleteTask, advanceAllSubscriptions, checkCapacity, checkMessageStatus, 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

AMQPriorityQueue

protected AMQPriorityQueue(org.apache.qpid.framing.AMQShortString name,
                           boolean durable,
                           org.apache.qpid.framing.AMQShortString owner,
                           boolean autoDelete,
                           boolean exclusive,
                           VirtualHost virtualHost,
                           int priorities,
                           Map<String,Object> arguments)

AMQPriorityQueue

public AMQPriorityQueue(String queueName,
                        boolean durable,
                        String owner,
                        boolean autoDelete,
                        boolean exclusive,
                        VirtualHost virtualHost,
                        int priorities,
                        Map<String,Object> arguments)
Method Detail

getPriorities

public int getPriorities()

checkSubscriptionsNotAheadOfDelivery

protected void checkSubscriptionsNotAheadOfDelivery(QueueEntry entry)
Overrides:
checkSubscriptionsNotAheadOfDelivery in class SimpleAMQQueue


Licensed to the Apache Software Foundation