diff --git a/components/shared/dse_shared_libs/message_broker_wrapper.py b/components/shared/dse_shared_libs/message_broker_wrapper.py index fb38810..8ae2e65 100644 --- a/components/shared/dse_shared_libs/message_broker_wrapper.py +++ b/components/shared/dse_shared_libs/message_broker_wrapper.py @@ -17,7 +17,7 @@ class MBWrapper: _channel: pika.BlockingConnection.channel def __init__(self, - host: str = 'localhost', + host: str = 'rabbitmq', exchange_type: str = 'fanout', exchange_name: str = None, callback: callable = None,