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 | a8c045167be7989a615957f44821660d721b5a2c (patch) | |
| tree | c38c545868b7def2d55a667c2720de7a96aad20f | |
| parent | 0da0a59418c096a02016e032c5adc7b80374ccf9 (diff) | |
| download | rabbitmq-server-a8c045167be7989a615957f44821660d721b5a2c.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 d4c2dee0..1551795f 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 |