Trace Retrieval: message handling with working json parser

modules/messaging/MessageReceiver.py

@@ -81,6 +81,9 @@ class MessageReceiver:
 
     def stop(self):
         '''Stops listening for messages and closes the connection'''
-        self._connection.ioloop.stop()
-        self._connection.close()
-        LOGGER.info(f"RabbitMQ connection closed")
\ No newline at end of file
+        try:
+            self._connection.ioloop.stop()
+            self._connection.close()
+            LOGGER.info("RabbitMQ connection closed")
+        except pika.exceptions.ConnectionWrongStateError:
+            LOGGER.warning("RabbitMQ connection already closed")

transaction-hub-in/trace-retrieval-microservice/app/messaging/MessageHandler.py

@@ -25,7 +25,7 @@ class MessageHandler:
             return
         
         if message['type'] == 'blockchain-transaction':
-            self.handle_blockchain_transaction(json.loads(message['content']))
+            self.handle_blockchain_transaction(message['content'])
             
     def handle_blockchain_transaction(self, transaction):
         self._mongo_repo.insert_trace(transaction)