diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 7 |
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; |