diff options
author | Julien Danjou <julien@danjou.info> | 2015-09-25 17:42:56 +0200 |
---|---|---|
committer | Julien Danjou <julien@danjou.info> | 2015-12-16 15:01:07 +0100 |
commit | 38af0f6b646c60f606263ce567b7afba189f0bf7 (patch) | |
tree | e79e90270138091149119022ed9fdceb9c904574 /ceilometer/messaging.py | |
parent | 512b7f067865f622f75c37cd83c892c614a21e9c (diff) | |
download | ceilometer-38af0f6b646c60f606263ce567b7afba189f0bf7.tar.gz |
collector: remove deprecated RPC code
Change-Id: I995398ee239754a4d333460112700caeec516eb5
Diffstat (limited to 'ceilometer/messaging.py')
-rw-r--r-- | ceilometer/messaging.py | 17 |
1 files changed, 0 insertions, 17 deletions
diff --git a/ceilometer/messaging.py b/ceilometer/messaging.py index 824ffbc8..c56ea21c 100644 --- a/ceilometer/messaging.py +++ b/ceilometer/messaging.py @@ -81,23 +81,6 @@ _SERIALIZER = RequestContextSerializer( oslo_serializer.JsonPayloadSerializer()) -def get_rpc_server(transport, topic, endpoint): - """Return a configured oslo_messaging rpc server.""" - cfg.CONF.import_opt('host', 'ceilometer.service') - target = oslo_messaging.Target(server=cfg.CONF.host, topic=topic) - return oslo_messaging.get_rpc_server(transport, target, - [endpoint], executor='threading', - serializer=_SERIALIZER) - - -def get_rpc_client(transport, retry=None, **kwargs): - """Return a configured oslo_messaging RPCClient.""" - target = oslo_messaging.Target(**kwargs) - return oslo_messaging.RPCClient(transport, target, - serializer=_SERIALIZER, - retry=retry) - - def get_notification_listener(transport, targets, endpoints, allow_requeue=False): """Return a configured oslo_messaging notification listener.""" |