From ebceb6036bca601e586cae1dd4d81a640014749f Mon Sep 17 00:00:00 2001 From: Derek Horton Date: Thu, 1 Aug 2019 14:49:16 -0500 Subject: [PATCH] Minor message processing cleanup --- app/queue/ingress.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/app/queue/ingress.py b/app/queue/ingress.py index 3743bbed3..fac915c12 100644 --- a/app/queue/ingress.py +++ b/app/queue/ingress.py @@ -26,11 +26,11 @@ class OperationSchema(Schema): @metrics.ingress_message_parsing_time.time() def parse_operation_message(message): try: - parsed_message = json.loads(message.value) + parsed_message = json.loads(message) except Exception: # The "extra" dict cannot have a key named "msg" or "message" # otherwise an exception in thrown in the logging code - logger.exception("Unable to parse json message from message queue", extra={"incoming_message": message.value}) + logger.exception("Unable to parse json message from message queue", extra={"incoming_message": message}) metrics.ingress_message_parsing_failure.inc() raise @@ -90,7 +90,7 @@ def event_loop(consumer, flask_app, event_producer, handler=handle_message): for msg in consumer: logger.debug("Message received") try: - handler(msg, event_producer) + handler(msg.value, event_producer) metrics.ingress_message_handler_success.inc() except Exception: metrics.ingress_message_handler_failure.inc()