Previous topic

The nova.rpc.impl_carrot Module

Next topic

The nova.rpc.impl_kombu Module

This Page

Psst... hey. You're reading the latest content, but it might be out of sync with code. You can read Nova 2011.2 docs or all OpenStack docs too.

The nova.rpc.impl_fake Module

Fake RPC implementation which calls proxy methods directly with no queues. Casts will block, but this is very useful for tests.

class Connection

Bases: object

Connection object.

close()
consume_in_thread()
create_consumer(topic, proxy, fanout=False)
class Consumer(topic, proxy)

Bases: object

call(context, method, args, timeout)
class RpcContext(*args, **kwargs)

Bases: nova.context.RequestContext

reply(reply=None, failure=None, ending=False)
call(context, topic, msg, timeout=None)

Sends a message on a topic and wait for a response.

cast(context, topic, msg)
check_serialize(msg)

Make sure a message intended for rpc can be serialized.

cleanup()
create_connection(new=True)

Create a connection

fanout_cast(context, topic, msg)

Cast to all consumers of a topic

multicall(context, topic, msg, timeout=None)

Make a call that returns multiple times.

notify(context, topic, msg)