The openstack_dashboard.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 openstack_dashboard.openstack.common.rpc.impl_fake.Connection[source]

Bases: object

Connection object.

Connection.close()[source]
Connection.consume_in_thread()[source]
Connection.create_consumer(topic, proxy, fanout=False)[source]
class openstack_dashboard.openstack.common.rpc.impl_fake.Consumer(topic, proxy)[source]

Bases: object

Consumer.call(context, version, method, namespace, args, timeout)[source]
class openstack_dashboard.openstack.common.rpc.impl_fake.RpcContext(**kwargs)[source]

Bases: openstack_dashboard.openstack.common.rpc.common.CommonRpcContext

RpcContext.deepcopy()[source]
RpcContext.reply(reply=None, failure=None, ending=False)[source]
openstack_dashboard.openstack.common.rpc.impl_fake.call(conf, context, topic, msg, timeout=None)[source]

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

openstack_dashboard.openstack.common.rpc.impl_fake.cast(conf, context, topic, msg)[source]
openstack_dashboard.openstack.common.rpc.impl_fake.check_serialize(msg)[source]

Make sure a message intended for rpc can be serialized.

openstack_dashboard.openstack.common.rpc.impl_fake.cleanup()[source]
openstack_dashboard.openstack.common.rpc.impl_fake.create_connection(conf, new=True)[source]

Create a connection.

openstack_dashboard.openstack.common.rpc.impl_fake.fanout_cast(conf, context, topic, msg)[source]

Cast to all consumers of a topic.

openstack_dashboard.openstack.common.rpc.impl_fake.multicall(conf, context, topic, msg, timeout=None)[source]

Make a call that returns multiple times.

openstack_dashboard.openstack.common.rpc.impl_fake.notify(conf, context, topic, msg, envelope)[source]

Previous topic

The openstack_dashboard.openstack.common.rpc.amqp Module

Next topic

The openstack_dashboard.openstack.common.rpc.impl_zmq Module

This Page