AMQP-based RPC.
Queues have consumers and publishers.
No fan-out support yet.
Bases: nova.rpc.impl_carrot.Consumer
Calls methods on a proxy object based on method and args.
Consumer callback to call a method on a proxy object.
Parses the message for validity and fires off a thread to call the proxy object method.
Example: {‘method’: ‘echo’, ‘args’: {‘value’: 42}}
Bases: carrot.connection.BrokerConnection
Connection instance object.
Cancel a consumer thread
Consumer from all queues/consumers in a greenthread
Create a consumer that calls methods in the proxy
Returns the instance.
Recreates the connection instance.
This is necessary to recover from some network errors/disconnects.
Bases: carrot.messaging.Consumer
Consumer base class.
Contains methods for connecting the fetch method to async loops.
Wraps the parent fetch with some logic for failed connection.
Bases: object
Groups consumers to listen on together on a single connection.
Bases: nova.rpc.impl_carrot.Consumer
Consumes messages directly on a channel specified by msg_id.
Bases: nova.rpc.impl_carrot.Publisher
Publishes messages directly on a channel specified by msg_id.
Bases: nova.rpc.impl_carrot.AdapterConsumer
Consumes messages from a fanout exchange.
Bases: nova.rpc.impl_carrot.Publisher
Publishes messages to a fanout exchange.
Bases: eventlet.pools.Pool
Class that implements a Pool of Connections.
Bases: carrot.messaging.Publisher
Publisher base class.
Bases: nova.context.RequestContext
Bases: nova.rpc.impl_carrot.AdapterConsumer
Consumes messages on a specific topic.
Bases: nova.rpc.impl_carrot.Publisher
Publishes messages on a specific 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.
Logs a result and exits.
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.
Sends a message for testing.