Merge branch 'main' of https://github.com/uug-ai/hub-pipeline-classifier

Author: cedricve

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: