|
26 | 26 | -export([update_limit/3, clear_limit/2, get_limit/2]).
|
27 | 27 | -export([validate/5, notify/4, notify_clear/3]).
|
28 | 28 | -export([connection_limit/1, queue_limit/1,
|
29 |
| - is_over_queue_limit/1, is_over_connection_limit/1]). |
| 29 | + is_over_queue_limit/1, is_over_connection_limit/1]). |
30 | 30 |
|
31 | 31 | -import(rabbit_misc, [pget/2, pget/3]).
|
32 | 32 |
|
@@ -59,21 +59,26 @@ connection_limit(VirtualHost) ->
|
59 | 59 | queue_limit(VirtualHost) ->
|
60 | 60 | get_limit(VirtualHost, <<"max-queues">>).
|
61 | 61 |
|
62 |
| --spec list() -> [{rabbit_types:vhost(), rabbit_types:infos()}]. |
63 | 62 |
|
64 |
| -list() -> |
65 |
| - case rabbit_runtime_parameters:list_component(<<"vhost-limits">>) of |
| 63 | +list0(VHost) -> |
| 64 | + case rabbit_runtime_parameters:list(VHost, <<"vhost-limits">>) of |
66 | 65 | [] -> [];
|
67 | 66 | Params -> [ {pget(vhost, Param), pget(value, Param)}
|
68 |
| - || Param <- Params, |
69 |
| - pget(value, Param) =/= undefined, |
70 |
| - pget(name, Param) == <<"limits">> ] |
| 67 | + || Param <- Params, |
| 68 | + pget(value, Param) =/= undefined, |
| 69 | + pget(name, Param) == <<"limits">> ] |
71 | 70 | end.
|
72 | 71 |
|
| 72 | + |
| 73 | +-spec list() -> [{rabbit_types:vhost(), rabbit_types:infos()}]. |
| 74 | + |
| 75 | +list() -> list0('_'). |
| 76 | + |
| 77 | + |
73 | 78 | -spec list(rabbit_types:vhost()) -> rabbit_types:infos().
|
74 | 79 |
|
75 |
| -list(VHost) -> |
76 |
| - rabbit_runtime_parameters:value(VHost, <<"vhost-limits">>, <<"limits">>, []). |
| 80 | +list(VHost) -> list0(VHost). |
| 81 | + |
77 | 82 |
|
78 | 83 | -spec is_over_connection_limit(rabbit_types:vhost()) -> {true, non_neg_integer()} | false.
|
79 | 84 |
|
|
0 commit comments