Skip to content

Commit dd9af24

Browse files
committed
exchange: fix message cache TTL override logic
Signed-off-by: Matteo Cafasso <[email protected]>
1 parent 341e5f1 commit dd9af24

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

lib/rabbit_message_deduplication_exchange.ex

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -174,7 +174,7 @@ defmodule RabbitMQ.MessageDeduplicationPlugin.Exchange do
174174

175175
# Whether to route the message or not.
176176
defp route?(exchange_name, message) do
177-
ttl = Common.message_header(message, "x-message-deduplication")
177+
ttl = Common.message_header(message, "x-cache-ttl")
178178
not Common.duplicate?(exchange_name, message, ttl)
179179
end
180180
end

0 commit comments

Comments
 (0)