diff --git a/tripleoclient/plugin.py b/tripleoclient/plugin.py
index 7b70e33c6..55c035a93 100644
--- a/tripleoclient/plugin.py
+++ b/tripleoclient/plugin.py
@@ -194,9 +194,9 @@ class ClientWrapper(object):
         self._local_orchestration = client
         return self._local_orchestration
 
-    def messaging_websocket(self):
+    def messaging_websocket(self, queue_name='tripleo'):
         """Returns a websocket for the messaging service"""
-        return WebsocketClient(self._instance)
+        return WebsocketClient(self._instance, queue_name)
 
     @property
     def object_store(self):