Merge pull request #110 from atlanticwave-sdx/fix/issue_102

Change ingress_port and egress_port with uni_a and uni_z respectively

swagger_server/messaging/topic_queue_consumer.py

@@ -93,7 +93,7 @@ def handle_mq_msg(self, msg_body):
         if is_json(msg_body):
             self.logger.info("JSON message")
             msg_json = json.loads(msg_body)
-            if "ingress_port" in msg_json and "egress_port" in msg_json:
+            if "uni_a" in msg_json and "uni_z" in msg_json:
                 self.logger.info("Got connection message.")
                 self.db_instance.add_key_value_pair_to_db(self.message_id, msg_body)
                 self.logger.info("Save to database complete.")