Compare commits
No commits in common. "a97d081bffd993167dc9c7daff78135a7d3b737d" and "87b6f7b9868ac7a7ebbba181c66801da59d9c9d4" have entirely different histories.
a97d081bff
...
87b6f7b986
@ -42,7 +42,7 @@ def setup_rabbit(mqtt_: MQTT) -> None:
|
|||||||
credentials = pika.PlainCredentials(config.RABBIT_USERNAME, config.RABBIT_PASSWORD)
|
credentials = pika.PlainCredentials(config.RABBIT_USERNAME, config.RABBIT_PASSWORD)
|
||||||
connection = pika.BlockingConnection(pika.ConnectionParameters(host=config.RABBIT_HOSTNAME,
|
connection = pika.BlockingConnection(pika.ConnectionParameters(host=config.RABBIT_HOSTNAME,
|
||||||
credentials=credentials,
|
credentials=credentials,
|
||||||
heartbeat=10,
|
heartbeat=0,
|
||||||
socket_timeout=5))
|
socket_timeout=5))
|
||||||
channel = connection.channel()
|
channel = connection.channel()
|
||||||
channel.exchange_declare(exchange=config.RABBIT_EXCHANGE,
|
channel.exchange_declare(exchange=config.RABBIT_EXCHANGE,
|
||||||
|
Loading…
Reference in New Issue
Block a user