diff --git a/sahara/tests/unit/utils/test_rpc.py b/sahara/tests/unit/utils/test_rpc.py
index 6b1f9ca6..1b2008aa 100644
--- a/sahara/tests/unit/utils/test_rpc.py
+++ b/sahara/tests/unit/utils/test_rpc.py
@@ -33,7 +33,7 @@ class TestMessagingSetup(base.SaharaTestCase):
         self.get_notify_transport = get_notif_transp_patch.start()
         self.patchers.append(get_notif_transp_patch)
 
-        get_transport_patch = mock.patch('oslo_messaging.get_transport')
+        get_transport_patch = mock.patch('oslo_messaging.get_rpc_transport')
         self.get_transport = get_transport_patch.start()
         self.patchers.append(get_transport_patch)
 
diff --git a/sahara/utils/rpc.py b/sahara/utils/rpc.py
index e7dbd60c..f6143b14 100644
--- a/sahara/utils/rpc.py
+++ b/sahara/utils/rpc.py
@@ -95,7 +95,7 @@ def setup_service_messaging():
     if MESSAGING_TRANSPORT:
         # Already is up
         return
-    MESSAGING_TRANSPORT = messaging.get_transport(cfg.CONF)
+    MESSAGING_TRANSPORT = messaging.get_rpc_transport(cfg.CONF)
 
 
 def setup_notifications():