diff options
author | Emile Joubert <emile@rabbitmq.com> | 2013-03-21 11:33:40 +0000 |
---|---|---|
committer | Emile Joubert <emile@rabbitmq.com> | 2013-03-21 11:33:40 +0000 |
commit | 4fd233bd49868359f55c50a509f7b87b8f55a8c5 (patch) | |
tree | 672562f168390fdcd1d000c293f55564df84ba42 | |
parent | ecc36c55bfd41a5eaf252057c87f5edc986bc35a (diff) | |
download | rabbitmq-server-4fd233bd49868359f55c50a509f7b87b8f55a8c5.tar.gz |
Modify decorator routing comment, variable and whitespace
-rw-r--r-- | src/rabbit_exchange_decorator.erl | 8 | ||||
-rw-r--r-- | src/rabbit_registry.erl | 5 |
2 files changed, 5 insertions, 8 deletions
diff --git a/src/rabbit_exchange_decorator.erl b/src/rabbit_exchange_decorator.erl index d8600835..45d0cbf5 100644 --- a/src/rabbit_exchange_decorator.erl +++ b/src/rabbit_exchange_decorator.erl @@ -57,12 +57,10 @@ -callback remove_bindings(serial(), rabbit_types:exchange(), [rabbit_types:binding()]) -> 'ok'. -%% %% called after exchange routing -%% %% return value is a list of queues to be added to the list of -%% %% destination queues. decorators must register separately for -%% %% this callback using exchange_decorator_route. +%% Decorators can optionally implement route/2 which allows additional +%% queues to be added to the routing decision. %% -callback route(rabbit_types:exchange(), rabbit_types:delivery()) -> -%% [rabbit_amqqueue:name()]. +%% [rabbit_amqqueue:name() | rabbit_types:exchange()]. -else. diff --git a/src/rabbit_registry.erl b/src/rabbit_registry.erl index 22700a7c..f6bc4071 100644 --- a/src/rabbit_registry.erl +++ b/src/rabbit_registry.erl @@ -95,13 +95,12 @@ internal_unregister(Class, TypeName) -> true = ets:delete(?ETS_NAME, UnregArg), ok. - %% (un)register exchange decorator route callback only when implemented %% to avoid decorators being called unnecessarily on the fast publishing path -conditional_register({{exchange_decorator, _Type}, ModuleName}) -> +conditional_register({{exchange_decorator, Type}, ModuleName}) -> case erlang:function_exported(ModuleName, route, 2) of true -> true = ets:insert(?ETS_NAME, - {{exchange_decorator_route, _Type}, + {{exchange_decorator_route, Type}, ModuleName}); false -> ok end; |