diff --git a/qinling/engine/service.py b/qinling/engine/service.py
index 07df1c42..e8eb3a83 100644
--- a/qinling/engine/service.py
+++ b/qinling/engine/service.py
@@ -44,7 +44,7 @@ class EngineService(service.Service):
 
         topic = CONF.engine.topic
         server = CONF.engine.host
-        transport = messaging.get_transport(CONF)
+        transport = messaging.get_rpc_transport(CONF)
         target = messaging.Target(topic=topic, server=server, fanout=False)
         endpoints = [engine.DefaultEngine(orchestrator)]
         access_policy = dispatcher.DefaultRPCAccessPolicy