change to rabbitmq
This commit is contained in:
@@ -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,
|
||||
|
||||
Reference in New Issue
Block a user