summaryrefslogtreecommitdiff
path: root/ceilometer/messaging.py
diff options
context:
space:
mode:
authorJulien Danjou <julien@danjou.info>2015-09-25 17:42:56 +0200
committerJulien Danjou <julien@danjou.info>2015-12-16 15:01:07 +0100
commit38af0f6b646c60f606263ce567b7afba189f0bf7 (patch)
treee79e90270138091149119022ed9fdceb9c904574 /ceilometer/messaging.py
parent512b7f067865f622f75c37cd83c892c614a21e9c (diff)
downloadceilometer-38af0f6b646c60f606263ce567b7afba189f0bf7.tar.gz
collector: remove deprecated RPC code
Change-Id: I995398ee239754a4d333460112700caeec516eb5
Diffstat (limited to 'ceilometer/messaging.py')
-rw-r--r--ceilometer/messaging.py17
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."""