This commit is contained in:
		@@ -42,8 +42,8 @@ def setup_rabbit(mqtt_: MQTT) -> None:
 | 
			
		||||
    credentials = pika.PlainCredentials(config.RABBIT_USERNAME, config.RABBIT_PASSWORD)
 | 
			
		||||
    connection = pika.BlockingConnection(pika.ConnectionParameters(host=config.RABBIT_HOSTNAME,
 | 
			
		||||
                                                                   credentials=credentials,
 | 
			
		||||
                                                                   heartbeat=10,
 | 
			
		||||
                                                                   socket_timeout=5))
 | 
			
		||||
                                                                   heartbeat=30,
 | 
			
		||||
                                                                   socket_timeout=45))
 | 
			
		||||
    channel = connection.channel()
 | 
			
		||||
    channel.exchange_declare(exchange=config.RABBIT_EXCHANGE,
 | 
			
		||||
                             exchange_type='fanout')
 | 
			
		||||
 
 | 
			
		||||
		Reference in New Issue
	
	Block a user