diff --git a/masakari/rpc.py b/masakari/rpc.py
index 1fe79031..85e05a28 100644
--- a/masakari/rpc.py
+++ b/masakari/rpc.py
@@ -42,7 +42,7 @@ EXTRA_EXMODS = []
 def init(conf):
     global TRANSPORT
     exmods = get_allowed_exmods()
-    TRANSPORT = messaging.get_transport(conf,
+    TRANSPORT = messaging.get_rpc_transport(conf,
                                         allowed_remote_exmods=exmods)