Pass the queue_name to messaging_websocket function for update

For update and upgrade, we need to pass a different queue name
to the websocket in order to read the ansible runtime
This review allow to pass another queue than the tripleo default
one

Change-Id: I7166093cf1a26969425b33f4442f45fa8dc707f0
This commit is contained in:
Mathieu Bultel 2018-02-14 13:54:34 +01:00
parent bd9bc4b212
commit b3fae6ee1a
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):