summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2012-06-08 15:20:45 +0100
committerSimon MacMullen <simon@rabbitmq.com>2012-06-08 15:20:45 +0100
commit432714c7516c59764b3071bc2cde1ac564a844b6 (patch)
treec38c545868b7def2d55a667c2720de7a96aad20f
parentde9b7e140e9fd5ef08d374f7f33252efee9fd729 (diff)
downloadrabbitmq-server-git-432714c7516c59764b3071bc2cde1ac564a844b6.tar.gz
Needed for tests
-rw-r--r--src/rabbit_policy.erl6
1 files changed, 5 insertions, 1 deletions
diff --git a/src/rabbit_policy.erl b/src/rabbit_policy.erl
index d4c2dee046..1551795f7c 100644
--- a/src/rabbit_policy.erl
+++ b/src/rabbit_policy.erl
@@ -16,6 +16,8 @@
-module(rabbit_policy).
+%% TODO specs
+
-behaviour(rabbit_runtime_parameter).
-include("rabbit.hrl").
@@ -47,7 +49,9 @@ set(X = #exchange{name = Name}) -> X#exchange{policy = set0(Name)}.
set0(Name) -> match(Name, list()).
get(Name, #amqqueue{policy = Policy}) -> get0(Name, Policy);
-get(Name, #exchange{policy = Policy}) -> get0(Name, Policy).
+get(Name, #exchange{policy = Policy}) -> get0(Name, Policy);
+%% Caution - SLOW.
+get(Name, EntityName = #resource{}) -> get0(Name, match(EntityName, list())).
get0(_Name, undefined) -> {error, not_found};
get0(Name, List) -> case pget(<<"policy">>, List) of