Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- -module(rabbit_exchange_type_test).
- -include_lib("rabbit_common/include/rabbit.hrl").
- -include_lib("rabbit_common/include/rabbit_framing.hrl").
- -behaviour(rabbit_exchange_type).
- -export([description/0, serialise_events/0, route/2]).
- -export([validate/1, create/2, delete/3, add_binding/3,
- remove_bindings/3, assert_args_equivalence/2]).
- -rabbit_boot_step({rabbit_exchange_type_test_registry,
- [{description, "test exchange type: registry"},
- {mfa, {rabbit_registry, register, [exchange, <<"x-test">>, ?MODULE]}},
- {requires, rabbit_registry},
- {enables, kernel_ready}]}).
- description() ->
- [{name, <<"x-test">>},
- {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).
- validate(_X) -> ok.
- create(_Tx, _X) -> ok.
- delete(_Tx, _X, _Bs) -> ok.
- policy_changed(_Tx, _X1, _X2) -> ok.
- add_binding(_Tx, _X, _B) -> ok.
- remove_bindings(_Tx, _X, _Bs) -> ok.
- assert_args_equivalence(X, Args) ->
- rabbit_exchange:assert_args_equivalence(X, Args).
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement