|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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 AMQQueue s. |
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)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |