From 72327ff6ab166b5d71350f8dc89bf8ad70d44c87 Mon Sep 17 00:00:00 2001 From: "ChangBo Guo(gcb)" Date: Sun, 19 Mar 2017 20:54:26 +0800 Subject: [PATCH] Remove old oslo.messaging transport aliases Those are remnants from the oslo-incubator times. Also, oslo.messaging deprecated [1] transport aliases since 5.2.0+ that is the minimal version supported for stable/newton. The patch that bumped the minimal version for Designate landed 3 months+ ago, so we can proceed ripping those aliases from the code base. [1] I314cefa5fb1803fa7e21e3e34300e5ced31bba89 Change-Id: Ic476ebb4fa8bbb0ef31020eee2214e04c58f1d60 Closes-Bug: #1424728 --- designate/rpc.py | 19 ++----------------- 1 file changed, 2 insertions(+), 17 deletions(-) diff --git a/designate/rpc.py b/designate/rpc.py index 44b6cacbc..87c8ee322 100644 --- a/designate/rpc.py +++ b/designate/rpc.py @@ -23,7 +23,6 @@ __all__ = [ 'get_client', 'get_server', 'get_notifier', - 'TRANSPORT_ALIASES', ] @@ -58,25 +57,11 @@ ALLOWED_EXMODS = [ EXTRA_EXMODS = [] -# NOTE(flaper87): The designate.openstack.common.rpc entries are -# for backwards compat with Havana rpc_backend configuration -# values. The designate.rpc entries are for compat with Folsom values. -TRANSPORT_ALIASES = { - 'designate.openstack.common.rpc.impl_kombu': 'rabbit', - 'designate.openstack.common.rpc.impl_qpid': 'qpid', - 'designate.openstack.common.rpc.impl_zmq': 'zmq', - 'designate.rpc.impl_kombu': 'rabbit', - 'designate.rpc.impl_qpid': 'qpid', - 'designate.rpc.impl_zmq': 'zmq', -} - - def init(conf): global TRANSPORT, NOTIFIER exmods = get_allowed_exmods() TRANSPORT = messaging.get_transport(conf, - allowed_remote_exmods=exmods, - aliases=TRANSPORT_ALIASES) + allowed_remote_exmods=exmods) serializer = RequestContextSerializer(JsonPayloadSerializer()) NOTIFIER = messaging.Notifier(TRANSPORT, serializer=serializer) @@ -186,7 +171,7 @@ class RPCDispatcher(rpc_dispatcher.RPCDispatcher): def get_transport_url(url_str=None): - return messaging.TransportURL.parse(CONF, url_str, TRANSPORT_ALIASES) + return messaging.TransportURL.parse(CONF, url_str) def get_client(target, version_cap=None, serializer=None):