root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Oops

This commit is contained in:
Simon MacMullen 2013-06-26 16:27:16 +01:00
parent 8992b1b5a7
commit 14d054b7e6
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
deps/rabbitmq_federation/src/rabbit_federation_queue_link.erl vendored
View File

@ -254,6 +254,9 @@ go(S0 = #not_started{run = Run,
unacked = Unacked}}
end, Upstream, UParams, QName, S0).
update_headers(UParams, Redelivered, undefined) ->
update_headers(UParams, Redelivered, []);
update_headers(UParams, Redelivered, Headers) ->
{table, Info} = rabbit_federation_upstream:params_to_table(UParams),
{Headers1, Count} =