diff --git a/os_namos/common/messaging.py b/os_namos/common/messaging.py
index cbee49c..a6bcd0c 100644
--- a/os_namos/common/messaging.py
+++ b/os_namos/common/messaging.py
@@ -64,7 +64,7 @@ def get_transport(url=None, optional=False, cache=True):
     transport = TRANSPORTS.get(cache_key)
     if not transport or not cache:
         try:
-            transport = oslo_messaging.get_transport(cfg.CONF, url,
+            transport = oslo_messaging.get_rpc_transport(cfg.CONF, url,
                                                      aliases=_ALIASES)
         except oslo_messaging.InvalidTransportURL as e:
             if not optional or e.url: