diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-06-12 16:36:18 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-06-12 16:36:18 +0100 |
| commit | 8992b1b5a7dc9eca08501cf390f077b8e4b893ab (patch) | |
| tree | 6d1287f5a021eebf4ac76ef6a5551d40cde57a63 /deps/rabbitmq_federation/src/rabbit_federation_upstream.erl | |
| parent | 177c8b18854f0f753caa4816a561e2fe8a50e59c (diff) | |
| download | rabbitmq-server-git-8992b1b5a7dc9eca08501cf390f077b8e4b893ab.tar.gz | |
Update headers when message forwarded.
Diffstat (limited to 'deps/rabbitmq_federation/src/rabbit_federation_upstream.erl')
| -rw-r--r-- | deps/rabbitmq_federation/src/rabbit_federation_upstream.erl | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/deps/rabbitmq_federation/src/rabbit_federation_upstream.erl b/deps/rabbitmq_federation/src/rabbit_federation_upstream.erl index 4dd3a63655..fe2d3d197b 100644 --- a/deps/rabbitmq_federation/src/rabbit_federation_upstream.erl +++ b/deps/rabbitmq_federation/src/rabbit_federation_upstream.erl @@ -46,10 +46,13 @@ for(XorQ, UpstreamName) -> params_to_table(#upstream_params{uri = URI, params = Params, x_or_q = XorQ}) -> + Key = case XorQ of + #exchange{} -> <<"exchange">>; + #amqqueue{} -> <<"queue">> + end, {table, [{<<"uri">>, longstr, remove_credentials(URI)}, {<<"virtual_host">>, longstr, vhost(Params)}, - %% TODO derp - {<<"exchange">>, longstr, name(XorQ)}]}. + {Key, longstr, name(XorQ)}]}. params_to_string(#upstream_params{uri = URI, x_or_q = XorQ}) -> |