x/cloudpulse
Code Issues Proposed changes

Remove old oslo.messaging transport aliases

Browse Source 
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.

Change-Id: If4cc66b1e3738e447ebcfec75419bca1970a33c1
This commit is contained in:
rajat29 2017-08-02 10:54:14 +05:30 committed by Anand Shanmugam
parent d606ecb996
commit 78fa31d41f
2 changed files with 2 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
cloudpulse/common/rpc.py
View File

@ -24,7 +24,6 @@ __all__ = [
'get_client',
'get_server',
'get_notifier',
'TRANSPORT_ALIASES',
]
from oslo_config import cfg
@ -47,14 +46,6 @@ EXTRA_EXMODS = []
# NOTE(lucasagomes): The cloudpulse.openstack.common.rpc entries are for
# backwards compat with IceHouse rpc_backend configuration values.
TRANSPORT_ALIASES = {
'cloudpulse.openstack.common.rpc.impl_kombu': 'rabbit',
'cloudpulse.openstack.common.rpc.impl_qpid': 'qpid',
'cloudpulse.openstack.common.rpc.impl_zmq': 'zmq',
'cloudpulse.rpc.impl_kombu': 'rabbit',
'cloudpulse.rpc.impl_qpid': 'qpid',
'cloudpulse.rpc.impl_zmq': 'zmq',
}
def init(conf):
@ -119,7 +110,7 @@ class RequestContextSerializer(messaging.Serializer):
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):

8
cloudpulse/common/rpc_service.py
View File

@ -33,11 +33,6 @@ eventlet.monkey_patch()
# NOTE(asalkeld):
# The cloudpulse.openstack.common.rpc entries are for compatibility
# with devstack rpc_backend configuration values.
TRANSPORT_ALIASES = {
'cloudpulse.openstack.common.rpc.impl_kombu': 'rabbit',
'cloudpulse.openstack.common.rpc.impl_qpid': 'qpid',
'cloudpulse.openstack.common.rpc.impl_zmq': 'zmq',
}
class RequestContextSerializer(messaging.Serializer):
@ -68,8 +63,7 @@ class Service(object):
def __init__(self, topic, server, handlers):
serializer = RequestContextSerializer(
objects_base.CloudpulseObjectSerializer())
transport = messaging.get_rpc_transport(cfg.CONF,
aliases=TRANSPORT_ALIASES)
transport = messaging.get_rpc_transport(cfg.CONF)
# TODO(asalkeld) add support for version='x.y'
target = messaging.Target(topic=topic, server=server)
access_policy = dispatcher.DefaultRPCAccessPolicy