Uses of Interface
org.apache.qpid.server.queue.AMQQueue

Packages that use AMQQueue
org.apache.qpid.qmf   
org.apache.qpid.server   
org.apache.qpid.server.binding   
org.apache.qpid.server.configuration   
org.apache.qpid.server.exchange   
org.apache.qpid.server.exchange.topic   
org.apache.qpid.server.handler   
org.apache.qpid.server.logging.actors   
org.apache.qpid.server.logging.subjects   
org.apache.qpid.server.message   
org.apache.qpid.server.queue   
org.apache.qpid.server.security   
org.apache.qpid.server.security.access   
org.apache.qpid.server.store   
org.apache.qpid.server.subscription   
org.apache.qpid.server.transport   
org.apache.qpid.server.virtualhost.plugins   
org.apache.qpid.server.virtualhost.plugins.policies   
org.apache.qpid.slowconsumerdetection.policies   
org.apache.qpid.tools.messagestore   
org.apache.qpid.tools.messagestore.commands   
 

Uses of AMQQueue in org.apache.qpid.qmf
 

Methods in org.apache.qpid.qmf with parameters of type AMQQueue
 boolean ManagementExchange.isBound(AMQQueue queue)
           
 boolean ManagementExchange.isBound(org.apache.qpid.framing.AMQShortString routingKey, AMQQueue queue)
           
 boolean ManagementExchange.isBound(org.apache.qpid.framing.AMQShortString routingKey, org.apache.qpid.framing.FieldTable arguments, AMQQueue queue)
           
 boolean ManagementExchange.isBound(String bindingKey, AMQQueue queue)
           
 

Uses of AMQQueue in org.apache.qpid.server
 

Methods in org.apache.qpid.server that return AMQQueue
 AMQQueue AMQChannel.getDefaultQueue()
           
 

Methods in org.apache.qpid.server with parameters of type AMQQueue
 void AMQChannel.block(AMQQueue queue)
           
 void AMQChannel.setDefaultQueue(AMQQueue queue)
           
 org.apache.qpid.framing.AMQShortString AMQChannel.subscribeToQueue(org.apache.qpid.framing.AMQShortString tag, AMQQueue queue, boolean acks, org.apache.qpid.framing.FieldTable filters, boolean noLocal, boolean exclusive)
          Subscribe to a queue.
 void AMQChannel.unblock(AMQQueue queue)
           
 

Uses of AMQQueue in org.apache.qpid.server.binding
 

Methods in org.apache.qpid.server.binding that return AMQQueue
 AMQQueue Binding.getQueue()
           
 

Methods in org.apache.qpid.server.binding with parameters of type AMQQueue
 boolean BindingFactory.addBinding(String bindingKey, AMQQueue queue, Exchange exchange, Map<String,Object> arguments)
           
 Binding BindingFactory.getBinding(String bindingKey, AMQQueue queue, Exchange exchange, Map<String,Object> arguments)
           
 Binding BindingFactory.removeBinding(String bindingKey, AMQQueue queue, Exchange exchange, Map<String,Object> arguments)
           
 boolean BindingFactory.replaceBinding(String bindingKey, AMQQueue queue, Exchange exchange, Map<String,Object> arguments)
           
 void BindingFactory.restoreBinding(String bindingKey, AMQQueue queue, Exchange exchange, Map<String,Object> argumentMap)
           
 

Constructors in org.apache.qpid.server.binding with parameters of type AMQQueue
Binding(UUID id, String bindingKey, AMQQueue queue, Exchange exchange, Map<String,Object> arguments)
           
 

Uses of AMQQueue in org.apache.qpid.server.configuration
 

Methods in org.apache.qpid.server.configuration with parameters of type AMQQueue
 ConfigurationPlugin ExchangeConfigurationPlugin.getConfiguration(AMQQueue queue)
           
 ConfigurationPlugin TopicConfiguration.getConfiguration(AMQQueue queue)
          This processes the given queue and apply configuration in the following order: Global Topic Values -> Topic Values -> Subscription Values
 ConfigurationPlugin VirtualHostConfiguration.getQueueConfiguration(AMQQueue queue)
           
 

Uses of AMQQueue in org.apache.qpid.server.exchange
 

Methods in org.apache.qpid.server.exchange with parameters of type AMQQueue
 boolean Exchange.isBound(AMQQueue queue)
           
 boolean DirectExchange.isBound(AMQQueue queue)
           
 boolean FanoutExchange.isBound(AMQQueue queue)
           
 boolean HeadersExchange.isBound(AMQQueue queue)
           
 boolean TopicExchange.isBound(AMQQueue queue)
           
 boolean Exchange.isBound(org.apache.qpid.framing.AMQShortString routingKey, AMQQueue queue)
          Determines whether a message would be isBound to a particular queue using a specific routing key
 boolean DirectExchange.isBound(org.apache.qpid.framing.AMQShortString routingKey, AMQQueue queue)
           
 boolean FanoutExchange.isBound(org.apache.qpid.framing.AMQShortString routingKey, AMQQueue queue)
           
 boolean HeadersExchange.isBound(org.apache.qpid.framing.AMQShortString routingKey, AMQQueue queue)
           
 boolean TopicExchange.isBound(org.apache.qpid.framing.AMQShortString routingKey, AMQQueue queue)
           
 boolean Exchange.isBound(org.apache.qpid.framing.AMQShortString routingKey, org.apache.qpid.framing.FieldTable arguments, AMQQueue queue)
          Determines whether a message would be isBound to a particular queue using a specific routing key and arguments
 boolean DirectExchange.isBound(org.apache.qpid.framing.AMQShortString routingKey, org.apache.qpid.framing.FieldTable arguments, AMQQueue queue)
           
 boolean FanoutExchange.isBound(org.apache.qpid.framing.AMQShortString routingKey, org.apache.qpid.framing.FieldTable arguments, AMQQueue queue)
           
 boolean HeadersExchange.isBound(org.apache.qpid.framing.AMQShortString routingKey, org.apache.qpid.framing.FieldTable arguments, AMQQueue queue)
           
 boolean TopicExchange.isBound(org.apache.qpid.framing.AMQShortString routingKey, org.apache.qpid.framing.FieldTable arguments, AMQQueue queue)
           
 boolean Exchange.isBound(String bindingKey, AMQQueue queue)
           
 boolean AbstractExchange.isBound(String bindingKey, AMQQueue queue)
           
 boolean AbstractExchange.isBound(String bindingKey, Map<String,Object> arguments, AMQQueue queue)
           
 

Uses of AMQQueue in org.apache.qpid.server.exchange.topic
 

Methods in org.apache.qpid.server.exchange.topic that return types with arguments of type AMQQueue
 Collection<AMQQueue> TopicExchangeResult.getUnfilteredQueues()
           
 Collection<AMQQueue> TopicExchangeResult.processMessage(InboundMessage msg, Collection<AMQQueue> queues)
           
 

Methods in org.apache.qpid.server.exchange.topic with parameters of type AMQQueue
 void TopicExchangeResult.addFilteredQueue(AMQQueue queue, MessageFilter filter)
           
 void TopicExchangeResult.addUnfilteredQueue(AMQQueue queue)
           
 void TopicExchangeResult.removeFilteredQueue(AMQQueue queue, MessageFilter filter)
           
 void TopicExchangeResult.removeUnfilteredQueue(AMQQueue queue)
           
 void TopicExchangeResult.replaceQueueFilter(AMQQueue queue, MessageFilter oldFilter, MessageFilter newFilter)
           
 

Method parameters in org.apache.qpid.server.exchange.topic with type arguments of type AMQQueue
 Collection<AMQQueue> TopicExchangeResult.processMessage(InboundMessage msg, Collection<AMQQueue> queues)
           
 

Uses of AMQQueue in org.apache.qpid.server.handler
 

Methods in org.apache.qpid.server.handler that return AMQQueue
protected  AMQQueue QueueDeclareHandler.createQueue(org.apache.qpid.framing.AMQShortString queueName, org.apache.qpid.framing.QueueDeclareBody body, VirtualHost virtualHost, AMQProtocolSession session)
           
 

Methods in org.apache.qpid.server.handler with parameters of type AMQQueue
static boolean BasicGetMethodHandler.performGet(AMQQueue queue, AMQProtocolSession session, AMQChannel channel, boolean acks)
           
 

Uses of AMQQueue in org.apache.qpid.server.logging.actors
 

Constructors in org.apache.qpid.server.logging.actors with parameters of type AMQQueue
QueueActor(AMQQueue queue, RootMessageLogger rootLogger)
          Create an QueueLogSubject that Logs in the following format.
 

Uses of AMQQueue in org.apache.qpid.server.logging.subjects
 

Constructors in org.apache.qpid.server.logging.subjects with parameters of type AMQQueue
BindingLogSubject(String routingKey, Exchange exchange, AMQQueue queue)
          Create a BindingLogSubject that Logs in the following format.
QueueLogSubject(AMQQueue queue)
          Create an QueueLogSubject that Logs in the following format.
 

Uses of AMQQueue in org.apache.qpid.server.message
 

Methods in org.apache.qpid.server.message with parameters of type AMQQueue
 boolean AMQMessage.expired(AMQQueue queue)
          Checks to see if the message has expired.
 

Uses of AMQQueue in org.apache.qpid.server.queue
 

Classes in org.apache.qpid.server.queue that implement AMQQueue
 class AMQPriorityQueue
           
 class ConflationQueue
           
 class SimpleAMQQueue
           
 

Methods in org.apache.qpid.server.queue that return AMQQueue
static AMQQueue AMQQueueFactory.createAMQQueueImpl(org.apache.qpid.framing.AMQShortString name, boolean durable, org.apache.qpid.framing.AMQShortString owner, boolean autoDelete, boolean exclusive, VirtualHost virtualHost, org.apache.qpid.framing.FieldTable arguments)
           
static AMQQueue AMQQueueFactory.createAMQQueueImpl(QueueConfiguration config, VirtualHost host)
           
static AMQQueue AMQQueueFactory.createAMQQueueImpl(String queueName, boolean durable, String owner, boolean autoDelete, boolean exclusive, VirtualHost virtualHost, Map<String,Object> arguments)
           
 AMQQueue QueueEntry.getQueue()
           
 AMQQueue QueueEntryImpl.getQueue()
           
 AMQQueue SimpleQueueEntryList.getQueue()
           
 AMQQueue QueueEntryList.getQueue()
           
 AMQQueue PriorityQueueList.getQueue()
           
 AMQQueue QueueRegistry.getQueue(org.apache.qpid.framing.AMQShortString name)
           
 AMQQueue DefaultQueueRegistry.getQueue(org.apache.qpid.framing.AMQShortString name)
           
 AMQQueue QueueRegistry.getQueue(String queue)
           
 AMQQueue DefaultQueueRegistry.getQueue(String queue)
           
 

Methods in org.apache.qpid.server.queue that return types with arguments of type AMQQueue
 Collection<AMQQueue> QueueRegistry.getQueues()
           
 Collection<AMQQueue> DefaultQueueRegistry.getQueues()
           
 

Methods in org.apache.qpid.server.queue with parameters of type AMQQueue
 int SimpleAMQQueue.compareTo(AMQQueue o)
           
 QueueEntryList SimpleQueueEntryList.Factory.createQueueEntryList(AMQQueue queue)
           
 QueueEntryList QueueEntryListFactory.createQueueEntryList(AMQQueue queue)
           
 QueueEntryList ConflationQueueList.Factory.createQueueEntryList(AMQQueue queue)
           
 QueueEntryList PriorityQueueList.Factory.createQueueEntryList(AMQQueue queue)
           
 void AMQQueue.Task.doTask(AMQQueue queue)
           
 void QueueNotificationListener.notifyClients(NotificationCheck notification, AMQQueue queue, String notificationMsg)
           
 void AMQQueueMBean.notifyClients(NotificationCheck notification, AMQQueue queue, String notificationMsg)
          Sends the notification to the listeners
(package private) abstract  boolean NotificationCheck.notifyIfNecessary(ServerMessage msg, AMQQueue queue, QueueNotificationListener listener)
           
 void QueueRegistry.registerQueue(AMQQueue queue)
           
 void DefaultQueueRegistry.registerQueue(AMQQueue queue)
           
 

Constructors in org.apache.qpid.server.queue with parameters of type AMQQueue
AMQQueueMBean(AMQQueue queue)
           
ConflationQueueList(AMQQueue queue, String conflationKey)
           
PriorityQueueList(AMQQueue queue, int priorities)
           
SimpleQueueEntryList(AMQQueue queue)
           
 

Uses of AMQQueue in org.apache.qpid.server.security
 

Methods in org.apache.qpid.server.security with parameters of type AMQQueue
 boolean SecurityManager.authoriseBind(Exchange exch, AMQQueue queue, org.apache.qpid.framing.AMQShortString routingKey)
           
 boolean SecurityManager.authoriseConsume(AMQQueue queue)
           
 boolean SecurityManager.authoriseConsume(boolean exclusive, boolean noAck, boolean noLocal, boolean nowait, AMQQueue queue)
           
 boolean SecurityManager.authoriseDelete(AMQQueue queue)
           
 boolean SecurityManager.authorisePurge(AMQQueue queue)
           
 boolean SecurityManager.authoriseUnbind(Exchange exch, org.apache.qpid.framing.AMQShortString routingKey, AMQQueue queue)
           
 

Uses of AMQQueue in org.apache.qpid.server.security.access
 

Constructors in org.apache.qpid.server.security.access with parameters of type AMQQueue
ObjectProperties(AMQQueue queue)
           
ObjectProperties(Boolean exclusive, Boolean noAck, Boolean noLocal, Boolean nowait, AMQQueue queue)
           
ObjectProperties(Exchange exch, AMQQueue queue, org.apache.qpid.framing.AMQShortString routingKey)
           
 

Uses of AMQQueue in org.apache.qpid.server.store
 

Methods in org.apache.qpid.server.store that return types with arguments of type AMQQueue
 List<AMQQueue> MemoryMessageStore.createQueues()
           
 

Methods in org.apache.qpid.server.store with parameters of type AMQQueue
 void DurableConfigurationStore.bindQueue(Exchange exchange, org.apache.qpid.framing.AMQShortString routingKey, AMQQueue queue, org.apache.qpid.framing.FieldTable args)
          Binds the specified queue to an exchange with a routing key.
 void DerbyMessageStore.bindQueue(Exchange exchange, org.apache.qpid.framing.AMQShortString routingKey, AMQQueue queue, org.apache.qpid.framing.FieldTable args)
           
 void MemoryMessageStore.bindQueue(Exchange exchange, org.apache.qpid.framing.AMQShortString routingKey, AMQQueue queue, org.apache.qpid.framing.FieldTable args)
           
 void DurableConfigurationStore.createQueue(AMQQueue queue)
          Makes the specified queue persistent.
 void DerbyMessageStore.createQueue(AMQQueue queue)
           
 void MemoryMessageStore.createQueue(AMQQueue queue)
           
 void DurableConfigurationStore.createQueue(AMQQueue queue, org.apache.qpid.framing.FieldTable arguments)
          Makes the specified queue persistent.
 void DerbyMessageStore.createQueue(AMQQueue queue, org.apache.qpid.framing.FieldTable arguments)
           
 void MemoryMessageStore.createQueue(AMQQueue queue, org.apache.qpid.framing.FieldTable arguments)
           
 void DurableConfigurationStore.removeQueue(AMQQueue queue)
          Removes the specified queue from the persistent store.
 void DerbyMessageStore.removeQueue(AMQQueue queue)
           
 void MemoryMessageStore.removeQueue(AMQQueue queue)
           
 void DurableConfigurationStore.unbindQueue(Exchange exchange, org.apache.qpid.framing.AMQShortString routingKey, AMQQueue queue, org.apache.qpid.framing.FieldTable args)
          Unbinds the specified from an exchange under a particular routing key.
 void DerbyMessageStore.unbindQueue(Exchange exchange, org.apache.qpid.framing.AMQShortString routingKey, AMQQueue queue, org.apache.qpid.framing.FieldTable args)
           
 void MemoryMessageStore.unbindQueue(Exchange exchange, org.apache.qpid.framing.AMQShortString routingKey, AMQQueue queue, org.apache.qpid.framing.FieldTable args)
           
 void DurableConfigurationStore.updateQueue(AMQQueue queue)
          Updates the specified queue in the persistent store, IF it is already present.
 void DerbyMessageStore.updateQueue(AMQQueue queue)
          Updates the specified queue in the persistent store, IF it is already present.
 void MemoryMessageStore.updateQueue(AMQQueue queue)
           
 

Uses of AMQQueue in org.apache.qpid.server.subscription
 

Methods in org.apache.qpid.server.subscription that return AMQQueue
 AMQQueue Subscription.getQueue()
           
 AMQQueue SubscriptionImpl.getQueue()
           
 AMQQueue Subscription_0_10.getQueue()
           
 

Methods in org.apache.qpid.server.subscription with parameters of type AMQQueue
 void Subscription.queueDeleted(AMQQueue queue)
           
 void SubscriptionImpl.queueDeleted(AMQQueue queue)
          Callback indicating that a queue has been deleted.
 void Subscription_0_10.queueDeleted(AMQQueue queue)
           
 void Subscription.setQueue(AMQQueue queue, boolean exclusive)
           
 void SubscriptionImpl.setQueue(AMQQueue queue, boolean exclusive)
           
 void Subscription_0_10.setQueue(AMQQueue queue, boolean exclusive)
           
 

Constructors in org.apache.qpid.server.subscription with parameters of type AMQQueue
SubscriptionList(AMQQueue queue)
           
 

Uses of AMQQueue in org.apache.qpid.server.transport
 

Methods in org.apache.qpid.server.transport that return AMQQueue
protected  AMQQueue ServerSessionDelegate.createQueue(String queueName, org.apache.qpid.transport.QueueDeclare body, VirtualHost virtualHost, ServerSession session)
           
 

Uses of AMQQueue in org.apache.qpid.server.virtualhost.plugins
 

Methods in org.apache.qpid.server.virtualhost.plugins that return types with arguments of type AMQQueue
 Set<AMQQueue> ConfiguredQueueBindingListener.getQueueCache()
          Lookup and return the cache of configured AMQQueues.
 

Uses of AMQQueue in org.apache.qpid.server.virtualhost.plugins.policies
 

Methods in org.apache.qpid.server.virtualhost.plugins.policies with parameters of type AMQQueue
 void TopicDeletePolicy.performPolicy(AMQQueue q)
           
 

Uses of AMQQueue in org.apache.qpid.slowconsumerdetection.policies
 

Methods in org.apache.qpid.slowconsumerdetection.policies with parameters of type AMQQueue
 void SlowConsumerPolicyPlugin.performPolicy(AMQQueue Queue)
           
 

Uses of AMQQueue in org.apache.qpid.tools.messagestore
 

Methods in org.apache.qpid.tools.messagestore that return AMQQueue
 AMQQueue MessageStoreTool.State.getQueue()
           
 

Methods in org.apache.qpid.tools.messagestore with parameters of type AMQQueue
 void MessageStoreTool.State.setQueue(AMQQueue queue)
           
 

Uses of AMQQueue in org.apache.qpid.tools.messagestore.commands
 

Methods in org.apache.qpid.tools.messagestore.commands with parameters of type AMQQueue
protected  boolean Move.checkRequirements(AMQQueue fromQueue, AMQQueue toQueue, List<Long> msgids)
           
protected  boolean Purge.checkRequirements(AMQQueue fromQueue, AMQQueue toQueue, List<Long> msgids)
           
protected  void Move.doCommand(AMQQueue fromQueue, long start, long id, AMQQueue toQueue)
           
protected  void Purge.doCommand(AMQQueue fromQueue, long start, long end, AMQQueue toQueue)
           
protected  void Copy.doCommand(AMQQueue fromQueue, long start, long end, AMQQueue toQueue)
           
 



Licensed to the Apache Software Foundation