From 3c0386adefa026305cdd8a5b4535e544ed4ab8d2 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?C=C3=A9dric=20Verstraeten?= Date: Thu, 9 Jan 2025 16:16:05 +0100 Subject: [PATCH] Fix connect method (no uppercase) --- utils/message_brokers.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/utils/message_brokers.py b/utils/message_brokers.py index c7a6654..4dc3a2e 100644 --- a/utils/message_brokers.py +++ b/utils/message_brokers.py @@ -140,7 +140,7 @@ def receive_message(self) -> list[dict]: # Check if connection to RabbitMQ is open, if not, reconnect if not self.connection.is_open: print("Connection to RabbitMQ is not open") - self.Connect() + self.connect() # Check if readChannel is closed, if yes, reinitialize if self.readChannel.is_closed: @@ -177,7 +177,7 @@ def send_message(self, message: str): # Handle connection and channel closure exceptions except pika.exceptions.ConnectionClosed: print('Reconnecting to queue') - self.Connect() + self.connect() self.publishChannel.basic_publish( exchange=self.exchange, routing_key=self.target_queue_name, body=message) except pika.exceptions.ChannelClosed: