Bases: object
Connection object.
Cancel a consumer thread
Close/release this connection
Callback when there are connection re-tries by kombu
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 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
Send to a publisher based on the publisher class
Handles reconnecting and re-estblishing queues
Reset a connection so it can be used again
Send a ‘topic’ message
Bases: object
The class that is actually returned to the caller of create_connection(). This is a essentially a wrapper around Connection that supports ‘with’ and can return a new Connection or one from a pool. It will also catch when an instance of this class is to be deleted so that we can return Connections to the pool on exceptions and so forth without making the caller be responsible for catching all exceptions and making sure to return a connection to the pool.
Caller is done with this connection.
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: nova.rpc.impl_kombu.ConsumerBase
Queue/consumer class for ‘direct’
Bases: nova.rpc.impl_kombu.Publisher
Publisher class for ‘direct’
Bases: nova.rpc.impl_kombu.ConsumerBase
Consumer class for ‘fanout’
Bases: nova.rpc.impl_kombu.Publisher
Publisher class for ‘fanout’
Bases: eventlet.pools.Pool
Class that implements a Pool of Connections.
Bases: object
Calls methods on a proxy object based on method and args.
Bases: object
Base Publisher class
Re-establish the Producer after a rabbit reconnection
Send a message
Bases: nova.context.RequestContext
Context that supports replying to a rpc.call
Bases: nova.rpc.impl_kombu.ConsumerBase
Consumer class for ‘topic’
Bases: nova.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.
Create a connection
Sends a message on a fanout exchange without waiting for a response.
Sends a reply or an error on the channel signified by msg_id.
Failure should be a sys.exc_info() tuple.
Make a call that returns multiple times.