Previous topic

The cinder.openstack.common.rpc.dispatcher Module

Next topic

The cinder.openstack.common.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 Cinder 2011.2 docs or all OpenStack docs too.

The cinder.openstack.common.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, version, method, args, timeout)
class RpcContext(**kwargs)

Bases: cinder.openstack.common.rpc.common.CommonRpcContext

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

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

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

Make sure a message intended for rpc can be serialized.

cleanup()
create_connection(conf, new=True)

Create a connection

fanout_cast(conf, context, topic, msg)

Cast to all consumers of a topic

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

Make a call that returns multiple times.

notify(conf, context, topic, msg)