Bases: object
Connection object.
Cancel a consumer thread.
Close/release this connection.
Consume from all queues/consumers.
Consumer from all queues/consumers in a greenthread.
Create a consumer that calls a method in a proxy object.
Create a worker that calls a method in a proxy object.
Create a Consumer using the class that was passed in and add it to our list of consumers
Create a ‘direct’ queue. In nova’s use, this is generally a msg_id queue used for responses for call/multicall
Create a ‘fanout’ consumer.
Create a ‘topic’ consumer.
Send a ‘direct’ message.
Send a ‘fanout’ message.
Convenience call for bin/clear_rabbit_queues.
Return an iterator that will consume from all queues/consumers.
Register as a member of a group of consumers for a given topic from the specified exchange.
Exactly one member of a given pool will receive each message.
A message will be delivered to multiple pools, if more than one is created.
Send a notify message on a topic.
Send to a publisher based on the publisher class.
Handles reconnecting and re-establishing queues. Will retry up to self.max_retries number of times. self.max_retries = 0 means to retry forever. Sleep between tries, starting at self.interval_start seconds, backing off self.interval_stepping number of seconds each attempt.
Reset a connection so it can be used again.
Send a ‘topic’ message.
Wait for all proxy callback threads to exit.
Bases: object
Consumer base class.
Cancel the consuming from the queue, if it has started.
Actually declare the consumer on the amqp channel. This will start the flow of messages from the queue. Using the Connection.iterconsume() iterator will process the messages, calling the appropriate callback.
If a callback is specified in kwargs, use that. Otherwise, use the callback passed during __init__()
If kwargs[‘nowait’] is True, then this call will block until a message is read.
Messages will automatically be acked if the callback doesn’t raise an exception
Re-declare the queue after a rabbit reconnect.
Bases: openstack_dashboard.openstack.common.rpc.impl_kombu.ConsumerBase
Queue/consumer class for ‘direct’.
Bases: openstack_dashboard.openstack.common.rpc.impl_kombu.Publisher
Publisher class for ‘direct’.
Bases: openstack_dashboard.openstack.common.rpc.impl_kombu.ConsumerBase
Consumer class for ‘fanout’.
Bases: openstack_dashboard.openstack.common.rpc.impl_kombu.Publisher
Publisher class for ‘fanout’.
Bases: openstack_dashboard.openstack.common.rpc.impl_kombu.TopicPublisher
Publisher class for ‘notify’.
Bases: object
Base Publisher class.
Re-establish the Producer after a rabbit reconnection.
Send a message.
Bases: openstack_dashboard.openstack.common.rpc.impl_kombu.ConsumerBase
Consumer class for ‘topic’.
Bases: openstack_dashboard.openstack.common.rpc.impl_kombu.Publisher
Publisher class for ‘topic’.
Sends a message on a topic and wait for a response.
Sends a message on a topic without waiting for a response.
Sends a message on a topic to a specific server.
Create a connection.
Sends a message on a fanout exchange without waiting for a response.
Sends a message on a fanout exchange to a specific server.
Make a call that returns multiple times.
Sends a notification event on a topic.