Bug Fix: Setting Generated Message ID as default value, skipping it w…

…hile already set (#90)
NeonGeckoCom · Jul 26, 2023 · 225fd13 · 225fd13
1 parent 58f2ad4
commit 225fd13
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/neon_mq_connector/connector.py b/neon_mq_connector/connector.py
@@ -363,10 +363,8 @@ def emit_mq_message(cls,
         :raises ValueError: invalid request data provided
         :returns message_id: id of the sent message
         """
-        if request_data and len(request_data) > 0 and isinstance(request_data,
-                                                                 dict):
-            message_id = cls.create_unique_id()
-            request_data['message_id'] = message_id
+        if request_data and len(request_data) > 0 and isinstance(request_data, dict):
+            message_id = request_data.setdefault('message_id', cls.create_unique_id())
             with connection.channel() as channel:
                 if exchange:
                     channel.exchange_declare(exchange=exchange,