summaryrefslogtreecommitdiff
path: root/deps/rabbitmq_federation/src
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2012-04-24 17:50:27 +0100
committerSimon MacMullen <simon@rabbitmq.com>2012-04-24 17:50:27 +0100
commit6526c4fdd4d7fd1a489e691d2cbd072687ad84f0 (patch)
tree2dd0f692cdd112c086f602b1c66d7d9958afa937 /deps/rabbitmq_federation/src
parent187e77598745bf6006105b4b45736eec9be05cba (diff)
downloadrabbitmq-server-git-6526c4fdd4d7fd1a489e691d2cbd072687ad84f0.tar.gz
API update
Diffstat (limited to 'deps/rabbitmq_federation/src')
-rw-r--r--deps/rabbitmq_federation/src/rabbit_federation_exchange.erl4
-rw-r--r--deps/rabbitmq_federation/src/rabbit_federation_link_sup.erl2
2 files changed, 3 insertions, 3 deletions
diff --git a/deps/rabbitmq_federation/src/rabbit_federation_exchange.erl b/deps/rabbitmq_federation/src/rabbit_federation_exchange.erl
index 3ff8182756..cb7de60d64 100644
--- a/deps/rabbitmq_federation/src/rabbit_federation_exchange.erl
+++ b/deps/rabbitmq_federation/src/rabbit_federation_exchange.erl
@@ -28,7 +28,7 @@
-behaviour(rabbit_exchange_decorator).
--export([description/0, serialise_events/0, route/2]).
+-export([description/0, serialise_events/1, route/2]).
-export([create/2, delete/3, add_binding/3, remove_bindings/3]).
%%----------------------------------------------------------------------------
@@ -37,7 +37,7 @@ description() ->
[{name, <<"federation">>},
{description, <<"Federation exchange decorator">>}].
-serialise_events() -> true.
+serialise_events(#exchange{name = XName}) -> federate(XName).
route(_X, _Delivery) -> ok.
diff --git a/deps/rabbitmq_federation/src/rabbit_federation_link_sup.erl b/deps/rabbitmq_federation/src/rabbit_federation_link_sup.erl
index ba4b3a28bf..3085eacc2b 100644
--- a/deps/rabbitmq_federation/src/rabbit_federation_link_sup.erl
+++ b/deps/rabbitmq_federation/src/rabbit_federation_link_sup.erl
@@ -94,7 +94,7 @@ upstreams(XName, ConnName) ->
[]
end.
-upstream_set(XName) ->
+upstream_set(_XName) ->
%% TODO ahem
<<"all">>.