AMQP-based RPC. Queues have consumers and publishers. No fan-out support yet.
Bases: nova.rpc.Consumer
Calls methods on a proxy object based on method and args
Bases: carrot.connection.BrokerConnection
Connection instance object
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
Only needed for unit tests!
Wraps the parent fetch with some logic for failed connections
Bases: nova.rpc.Consumer
Consumes messages directly on a channel specified by msg_id
Bases: nova.rpc.Publisher
Publishes messages directly on a channel specified by msg_id
Bases: nova.rpc.AdapterConsumer
Consumes messages from a fanout exchange
Bases: nova.rpc.Publisher
Publishes messages to a fanout exchange.
Bases: carrot.messaging.Publisher
Publisher base class
Bases: nova.exception.Error
Signifies that a remote class has raised an exception
Containes a string representation of the type of the original exception, the value of the original exception, and the traceback. These are sent to the parent as a joined string so printing the exception contains all of the relevent info.
Bases: nova.rpc.AdapterConsumer
Consumes messages on a specific topic
Bases: nova.rpc.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
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.
Sends a message for testing