diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-06-08 15:20:45 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-06-08 15:20:45 +0100 |
| commit | 432714c7516c59764b3071bc2cde1ac564a844b6 (patch) | |
| tree | c38c545868b7def2d55a667c2720de7a96aad20f | |
| parent | de9b7e140e9fd5ef08d374f7f33252efee9fd729 (diff) | |
| download | rabbitmq-server-git-432714c7516c59764b3071bc2cde1ac564a844b6.tar.gz | |
Needed for tests
| -rw-r--r-- | src/rabbit_policy.erl | 6 |
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 |
