Fake RPC implementation which calls proxy methods directly with no
queues. Casts will block, but this is very useful for tests.
-
class ceilometer.openstack.common.rpc.impl_fake.Connection[source]
Bases: object
Connection object.
-
close()[source]
-
consume_in_thread()[source]
-
create_consumer(topic, proxy, fanout=False)[source]
-
class ceilometer.openstack.common.rpc.impl_fake.Consumer(topic, proxy)[source]
Bases: object
-
call(context, version, method, args, timeout)[source]
-
class ceilometer.openstack.common.rpc.impl_fake.RpcContext(**kwargs)[source]
Bases: ceilometer.openstack.common.rpc.common.CommonRpcContext
-
deepcopy()[source]
-
reply(reply=None, failure=None, ending=False)[source]