Clean up

atlanticwave-sdx · Jan 13, 2025 · e29e7bc · e29e7bc
1 parent 039037e
commit e29e7bc
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 8 deletions.
diff --git a/sdx_controller/handlers/connection_handler.py b/sdx_controller/handlers/connection_handler.py
@@ -382,7 +382,6 @@ def get_connection_status(db, service_id: str):
         notifications = request_dict.get("notifications")
         oxp_response_code = request_dict.get("oxp_response_code")
         oxp_response = request_dict.get("oxp_response")
-        print(f"request_dict: {request_dict}")
         if request_dict.get("endpoints") is not None:  # spec version 2.0.0
             request_endpoints = request_dict.get("endpoints")
             request_uni_a = request_endpoints[0]

diff --git a/sdx_controller/messaging/topic_queue_producer.py b/sdx_controller/messaging/topic_queue_producer.py
@@ -64,13 +64,6 @@ def on_response(self, ch, method, props, body):
             self.response = body
 
     def call(self, body):
-        # if not self.connection or self.connection.is_closed:
-        #     # print("Reopening connection...")
-        #     self.connection = pika.BlockingConnection(pika.ConnectionParameters(host=MQ_HOST))
-        #     self.channel = self.connection.channel()
-        #     # print("Connection reopened.")
-        #     # channel.exchange_declare(exchange=self.exchange_name)
-
         self.response = None
         self.corr_id = str(uuid.uuid4())
         self.channel.exchange_declare(