Merge "Pass the queue_name to messaging_websocket function for update"

This commit is contained in:
Zuul 2018-02-15 16:51:52 +00:00 committed by Gerrit Code Review
commit ab9e28d21c
1 changed files with 2 additions and 2 deletions

View File

@ -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):