Fake RPC implementation which calls proxy methods directly with no
queues. Casts will block, but this is very useful for tests.
-
class quantum.openstack.common.rpc.impl_fake.Connection
Bases: object
Connection object.
-
close()
-
consume_in_thread()
-
create_consumer(topic, proxy, fanout=False)
-
class quantum.openstack.common.rpc.impl_fake.Consumer(topic, proxy)
Bases: object
-
call(context, version, method, args, timeout)
-
class quantum.openstack.common.rpc.impl_fake.RpcContext(**kwargs)
Bases: quantum.openstack.common.rpc.common.CommonRpcContext
-
deepcopy()
-
reply(reply=None, failure=None, ending=False)
-
quantum.openstack.common.rpc.impl_fake.call(conf, context, topic, msg, timeout=None)
Sends a message on a topic and wait for a response.
-
quantum.openstack.common.rpc.impl_fake.cast(conf, context, topic, msg)
-
quantum.openstack.common.rpc.impl_fake.check_serialize(msg)
Make sure a message intended for rpc can be serialized.
-
quantum.openstack.common.rpc.impl_fake.cleanup()
-
quantum.openstack.common.rpc.impl_fake.create_connection(conf, new=True)
Create a connection
-
quantum.openstack.common.rpc.impl_fake.fanout_cast(conf, context, topic, msg)
Cast to all consumers of a topic
-
quantum.openstack.common.rpc.impl_fake.multicall(conf, context, topic, msg, timeout=None)
Make a call that returns multiple times.
-
quantum.openstack.common.rpc.impl_fake.notify(conf, context, topic, msg, envelope)