diff --git a/uugai_python_dynamic_queue/MessageBrokers.py b/uugai_python_dynamic_queue/MessageBrokers.py
index 1a9740d..6bbd094 100644
--- a/uugai_python_dynamic_queue/MessageBrokers.py
+++ b/uugai_python_dynamic_queue/MessageBrokers.py
@@ -183,7 +183,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:
@@ -415,4 +415,4 @@ def close(self) -> bool:
         self.kafka_producer.close()
         
         return True
-    
\ No newline at end of file
+