from level appending delivery_tag

jookies · Jan 11, 2024 · d46cdb3 · d46cdb3
1 parent e9f8ab5
commit d46cdb3
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/jasmin/routing/throwers.py b/jasmin/routing/throwers.py
@@ -218,10 +218,8 @@ def ackMessage(self, message):
         yield self.amqpBroker.chan.basic_ack(message.delivery_tag)
 
     def getMessageUniqueId(self, message):
-        uniqueId = message.content.properties['message-id']
-        if 'headers' in message.content.properties and 'level' in message.content.properties['headers']:
-            uniqueId += '-%s' % message.content.properties['headers']['level']
-        return uniqueId
+        # get a unique id for this message. dlr level 1 and 2 are different payloads but share the same id
+        return '%s-%s' % (message.content.properties['message-id'], message.delivery_tag)
 
 
 class deliverSmThrower(Thrower):