diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2011-03-21 12:27:02 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2011-03-21 12:27:02 +0000 |
| commit | 05eb5fa6fff022148051b28c16744b82be982589 (patch) | |
| tree | cd9a46f253d2eb78b970c622b08fbc9085990dcd /src/rabbit_exchange_type_direct.erl | |
| parent | 5b5e7d0b3324a126c8b45aa33dc8d28e6046ae43 (diff) | |
| download | rabbitmq-server-05eb5fa6fff022148051b28c16744b82be982589.tar.gz | |
serialise_events should take an exchange really.
Diffstat (limited to 'src/rabbit_exchange_type_direct.erl')
| -rw-r--r-- | src/rabbit_exchange_type_direct.erl | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/rabbit_exchange_type_direct.erl b/src/rabbit_exchange_type_direct.erl index d1ea62f3..bc7a76e3 100644 --- a/src/rabbit_exchange_type_direct.erl +++ b/src/rabbit_exchange_type_direct.erl @@ -19,7 +19,7 @@ -behaviour(rabbit_exchange_type). --export([description/0, route/2, serialise_events/0]). +-export([description/0, route/2, serialise_events/1]). -export([validate/1, create/2, recover/2, delete/3, add_binding/3, remove_bindings/3, assert_args_equivalence/2]). -include("rabbit_exchange_type_spec.hrl"). @@ -35,12 +35,11 @@ description() -> [{name, <<"direct">>}, {description, <<"AMQP direct exchange, as per the AMQP specification">>}]. -serialise_events() -> false. - route(#exchange{name = Name}, #delivery{message = #basic_message{routing_keys = Routes}}) -> rabbit_router:match_routing_key(Name, Routes). +serialise_events(_X) -> false. validate(_X) -> ok. create(_Tx, _X) -> ok. recover(_X, _Bs) -> ok. |