diff --git a/watcher/common/rpc.py b/watcher/common/rpc.py
index c8aceeb05..49197a0ea 100644
--- a/watcher/common/rpc.py
+++ b/watcher/common/rpc.py
@@ -53,11 +53,10 @@ JsonPayloadSerializer = messaging.JsonPayloadSerializer
 def init(conf):
     global TRANSPORT, NOTIFICATION_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)
     NOTIFICATION_TRANSPORT = messaging.get_notification_transport(
-        conf,
-        allowed_remote_exmods=exmods)
+        conf, allowed_remote_exmods=exmods)
 
     serializer = RequestContextSerializer(JsonPayloadSerializer())
     if not conf.notification_level:
diff --git a/watcher/common/service.py b/watcher/common/service.py
index fda65c937..61bdd2ead 100644
--- a/watcher/common/service.py
+++ b/watcher/common/service.py
@@ -210,7 +210,7 @@ class Service(service.ServiceBase):
     @property
     def transport(self):
         if self._transport is None:
-            self._transport = om.get_transport(CONF)
+            self._transport = om.get_rpc_transport(CONF)
         return self._transport
 
     @property