summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorkjnilsson <knilsson@pivotal.io>2018-12-19 16:55:50 +0000
committerkjnilsson <knilsson@pivotal.io>2018-12-19 16:55:50 +0000
commit9987bef6d371653e0a5ba87b734b1cbf4a91444f (patch)
tree7cc2417bbcf475a6d4ee8b7126a60a622c1541c8 /src
parent4cf67e8089492aced3f819c105ffd4f89f0e5871 (diff)
downloadrabbitmq-server-git-9987bef6d371653e0a5ba87b734b1cbf4a91444f.tar.gz
Do not include x-delivery-count header on first delivery.
[#162755631]
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_channel.erl7
1 files changed, 4 insertions, 3 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl
index 996774fe35..d1f3b06528 100644
--- a/src/rabbit_channel.erl
+++ b/src/rabbit_channel.erl
@@ -2527,9 +2527,10 @@ maybe_monitor_all([], S) -> S; %% optimisation
maybe_monitor_all([Item], S) -> maybe_monitor(Item, S); %% optimisation
maybe_monitor_all(Items, S) -> lists:foldl(fun maybe_monitor/2, S, Items).
-add_delivery_count_header(MsgHeader, Msg) ->
- Count = maps:get(delivery_count, MsgHeader, 0),
- rabbit_basic:add_header(<<"x-delivery-count">>, long, Count, Msg).
+add_delivery_count_header(#{delivery_count := Count}, Msg) ->
+ rabbit_basic:add_header(<<"x-delivery-count">>, long, Count, Msg);
+add_delivery_count_header(_, Msg) ->
+ Msg.
qpid_to_ref(Pid) when is_pid(Pid) -> Pid;
qpid_to_ref({Name, _}) -> Name;