Format

atlanticwave-sdx · Jun 12, 2024 · 5791750 · 5791750
1 parent 40c87fc
commit 5791750
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/sdx_lc/messaging/topic_queue_consumer.py b/sdx_lc/messaging/topic_queue_consumer.py
@@ -93,7 +93,11 @@ def handle_mq_msg(self, msg_body):
         if is_json(msg_body):
             self.logger.info("JSON message")
             msg_json = json.loads(msg_body)
-            if "operation" in msg_json and "uni_a" in msg_json["link"] and "uni_z" in msg_json["link"]:
+            if (
+                "link" in msg_json
+                and "uni_a" in msg_json["link"]
+                and "uni_z" in msg_json["link"]
+            ):
                 connection = msg_json["link"]
                 self.logger.info("Got connection message.")
                 self.db_instance.add_key_value_pair_to_db(self.message_id, connection)