From d748264866fd4417a591ffc2eff0ca503d42b4c1 Mon Sep 17 00:00:00 2001
From: deepakmourya <deepak.mourya@nectechnologies.in>
Date: Wed, 7 Jun 2017 12:44:45 +0530
Subject: [PATCH] Use get_rpc_transport instead of get_transport

With the added get_rpc_transport() function in oslo.messaging [1]
and the recent version bump of oslo.messaging to 5.24.2, we can
safely replace get_transport() with get_rpc_transport() which is much
cleaner.

[1] https://review.openstack.org/#/c/454194/

Change-Id: I460bdcae7855cae189d9b61896b5ef78989a197e
---
 cloudpulse/common/rpc.py         | 5 ++---
 cloudpulse/common/rpc_service.py | 9 ++++-----
 2 files changed, 6 insertions(+), 8 deletions(-)

diff --git a/cloudpulse/common/rpc.py b/cloudpulse/common/rpc.py
index f1bc34b..03e6b87 100644
--- a/cloudpulse/common/rpc.py
+++ b/cloudpulse/common/rpc.py
@@ -59,9 +59,8 @@ TRANSPORT_ALIASES = {
 def init(conf):
     global TRANSPORT, NOTIFIER
     exmods = get_allowed_exmods()
-    TRANSPORT = messaging.get_transport(conf,
-                                        allowed_remote_exmods=exmods,
-                                        aliases=TRANSPORT_ALIASES)
+    TRANSPORT = messaging.get_rpc_transport(conf,
+                                            allowed_remote_exmods=exmods)
     serializer = RequestContextSerializer(JsonPayloadSerializer())
     NOTIFIER = messaging.Notifier(TRANSPORT, serializer=serializer)
 
diff --git a/cloudpulse/common/rpc_service.py b/cloudpulse/common/rpc_service.py
index e447b28..a117c6c 100644
--- a/cloudpulse/common/rpc_service.py
+++ b/cloudpulse/common/rpc_service.py
@@ -68,8 +68,8 @@ class Service(object):
     def __init__(self, topic, server, handlers):
         serializer = RequestContextSerializer(
             objects_base.CloudpulseObjectSerializer())
-        transport = messaging.get_transport(cfg.CONF,
-                                            aliases=TRANSPORT_ALIASES)
+        transport = messaging.get_rpc_transport(cfg.CONF,
+                                                aliases=TRANSPORT_ALIASES)
         # TODO(asalkeld) add support for version='x.y'
         target = messaging.Target(topic=topic, server=server)
         self._server = messaging.get_rpc_server(transport, target, handlers,
@@ -87,9 +87,8 @@ class API(object):
             objects_base.CloudpulseObjectSerializer())
         if transport is None:
             exmods = rpc.get_allowed_exmods()
-            transport = messaging.get_transport(cfg.CONF,
-                                                allowed_remote_exmods=exmods,
-                                                aliases=TRANSPORT_ALIASES)
+            transport = messaging.get_rpc_transport(
+                cfg.CONF, allowed_remote_exmods=exmods)
         self._context = context
         if topic is None:
             topic = ''