diff --git a/kosmos/common/rpc.py b/kosmos/common/rpc.py
index ef5bcf6..93ba34a 100644
--- a/kosmos/common/rpc.py
+++ b/kosmos/common/rpc.py
@@ -57,8 +57,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)