diff --git a/magnum/common/rpc.py b/magnum/common/rpc.py
index ddce2b9834..2da24de4eb 100644
--- a/magnum/common/rpc.py
+++ b/magnum/common/rpc.py
@@ -52,8 +52,8 @@ EXTRA_EXMODS = []
 def init(conf):
     global TRANSPORT, NOTIFIER
     exmods = get_allowed_exmods()
-    TRANSPORT = messaging.get_transport(conf,
-                                        allowed_remote_exmods=exmods)
+    TRANSPORT = messaging.get_rpc_transport(conf,
+                                            allowed_remote_exmods=exmods)
     serializer = RequestContextSerializer(JsonPayloadSerializer())
     NOTIFIER = messaging.Notifier(TRANSPORT, serializer=serializer)
 
diff --git a/magnum/common/rpc_service.py b/magnum/common/rpc_service.py
index 427b448a73..27818d4ead 100644
--- a/magnum/common/rpc_service.py
+++ b/magnum/common/rpc_service.py
@@ -46,7 +46,7 @@ class Service(service.Service):
     def __init__(self, topic, server, handlers, binary):
         super(Service, self).__init__()
         serializer = _init_serializer()
-        transport = messaging.get_transport(CONF)
+        transport = messaging.get_rpc_transport(CONF)
         # TODO(asalkeld) add support for version='x.y'
         target = messaging.Target(topic=topic, server=server)
         self._server = messaging.get_rpc_server(transport, target, handlers,
@@ -80,8 +80,8 @@ class API(object):
         serializer = _init_serializer()
         if transport is None:
             exmods = rpc.get_allowed_exmods()
-            transport = messaging.get_transport(CONF,
-                                                allowed_remote_exmods=exmods)
+            transport = messaging.get_rpc_transport(
+                CONF, allowed_remote_exmods=exmods)
         self._context = context
         if topic is None:
             topic = ''