Troubleshoot message_id handling for transactional routing

neon_mq_connector/connector.py

@@ -420,7 +420,8 @@ def send_message(self,
                      exchange: Optional[str] = '',
                      queue: Optional[str] = '',
                      exchange_type: ExchangeType = ExchangeType.direct,
-                     expiration: int = 1000) -> str:
+                     expiration: int = 1000,
+                     override_message_id: bool = True) -> str:
         """
         Wrapper method for creation the MQ connection and immediate propagation
         of requested message with that
@@ -434,6 +435,7 @@ def send_message(self,
         :param exchange_type: type of exchange to use
             (defaults to ExchangeType.direct)
         :param expiration: posted data expiration (in millis)
+        :param override_message_id: if True, generate a unique `message_id`
 
         :returns message_id: id of the propagated message
         """
@@ -454,12 +456,14 @@ def send_message(self,
             else:
                 LOG.debug(f'Sending {exchange_type} request to exchange '
                           f'{exchange}')
-                msg_id = self.emit_mq_message(mq_conn,
-                                              queue=queue,
-                                              request_data=request_data,
-                                              exchange=exchange,
-                                              exchange_type=exchange_type,
-                                              expiration=expiration)
+                msg_id = self.emit_mq_message(
+                    mq_conn,
+                    queue=queue,
+                    request_data=request_data,
+                    exchange=exchange,
+                    exchange_type=exchange_type,
+                    expiration=expiration,
+                    override_message_id=override_message_id)
         LOG.info(f'Message propagated, id={msg_id}')
         return msg_id