root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

updates interceptor to new behaviour spec

This commit is contained in:
Alvaro Videla 2014-01-22 19:36:33 +01:00
parent 56ad599a17
commit 93f5a20079
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
deps/rabbitmq_sharding/src/rabbit_sharding_interceptor.erl vendored
View File

@ -5,7 +5,7 @@
-behaviour(rabbit_channel_interceptor). -behaviour(rabbit_channel_interceptor).
-export([description/0, intercept/1, applies_to/1]). -export([description/0, intercept/2, applies_to/1]).
-import(rabbit_sharding_util, [a2b/1]). -import(rabbit_sharding_util, [a2b/1]).
@ -19,15 +19,15 @@
description() -> description() ->
[{description, <<"Sharding interceptor for channel methods">>}]. [{description, <<"Sharding interceptor for channel methods">>}].
intercept(#'basic.consume'{queue = QName} = Method) -> intercept(#'basic.consume'{queue = QName} = Method, _Vhost) ->
{ok, QName2} = queue_name(QName), {ok, QName2} = queue_name(QName),
{ok, Method#'basic.consume'{queue = QName2}}; {ok, Method#'basic.consume'{queue = QName2}};
intercept(#'basic.get'{queue = QName} = Method) -> intercept(#'basic.get'{queue = QName} = Method, _Vhost) ->
{ok, QName2} = queue_name(QName), {ok, QName2} = queue_name(QName),
{ok, Method#'basic.get'{queue = QName2}}; {ok, Method#'basic.get'{queue = QName2}};
intercept(#'queue.delete'{queue = QName} = Method) -> intercept(#'queue.delete'{queue = QName} = Method, _Vhost) ->
case is_sharded(QName) of case is_sharded(QName) of
true -> true ->
{error, rabbit_misc:format("Can't delete sharded queue: ~p", [QName])}; {error, rabbit_misc:format("Can't delete sharded queue: ~p", [QName])};
@ -35,7 +35,7 @@ intercept(#'queue.delete'{queue = QName} = Method) ->
{ok, Method} {ok, Method}
end; end;
intercept(#'queue.declare'{queue = QName} = Method) -> intercept(#'queue.declare'{queue = QName} = Method, _Vhost) ->
case is_sharded(QName) of case is_sharded(QName) of
true -> true ->
{error, rabbit_misc:format("Can't declare sharded queue: ~p", [QName])}; {error, rabbit_misc:format("Can't declare sharded queue: ~p", [QName])};
@ -43,7 +43,7 @@ intercept(#'queue.declare'{queue = QName} = Method) ->
{ok, Method} {ok, Method}
end; end;
intercept(#'queue.bind'{queue = QName} = Method) -> intercept(#'queue.bind'{queue = QName} = Method, _Vhost) ->
case is_sharded(QName) of case is_sharded(QName) of
true -> true ->
{error, rabbit_misc:format("Can't bind sharded queue: ~p", [QName])}; {error, rabbit_misc:format("Can't bind sharded queue: ~p", [QName])};
@ -51,7 +51,7 @@ intercept(#'queue.bind'{queue = QName} = Method) ->
{ok, Method} {ok, Method}
end; end;
intercept(#'queue.unbind'{queue = QName} = Method) -> intercept(#'queue.unbind'{queue = QName} = Method, _Vhost) ->
case is_sharded(QName) of case is_sharded(QName) of
true -> true ->
{error, rabbit_misc:format("Can't unbind sharded queue: ~p", [QName])}; {error, rabbit_misc:format("Can't unbind sharded queue: ~p", [QName])};
@ -59,7 +59,7 @@ intercept(#'queue.unbind'{queue = QName} = Method) ->
{ok, Method} {ok, Method}
end; end;
intercept(#'queue.purge'{queue = QName} = Method) -> intercept(#'queue.purge'{queue = QName} = Method, _Vhost) ->
case is_sharded(QName) of case is_sharded(QName) of
true -> true ->
{error, rabbit_misc:format("Can't purge sharded queue: ~p", [QName])}; {error, rabbit_misc:format("Can't purge sharded queue: ~p", [QName])};