diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2020-02-20 20:04:54 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2020-02-20 20:05:15 +0300 |
| commit | a5f8ac40c040cfcb51445065d9b76f59477b75c1 (patch) | |
| tree | d1b8bedeb0f7cafb40b4c0f545953899a7a573b5 | |
| parent | 278a1fedfb569b8b6b1dd56a44f0a01fa3500a43 (diff) | |
| download | rabbitmq-server-git-a5f8ac40c040cfcb51445065d9b76f59477b75c1.tar.gz | |
Compiles from scratch
| -rw-r--r-- | src/rabbit_definitions.erl | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/src/rabbit_definitions.erl b/src/rabbit_definitions.erl index 6336fe4f31..53fa159b29 100644 --- a/src/rabbit_definitions.erl +++ b/src/rabbit_definitions.erl @@ -352,8 +352,8 @@ do_concurrent_for_all(List, WorkPoolFun) -> fun() -> try WorkPoolFun(M) - catch _:E -> gatherer:in(Gatherer, {error, E}); - {error, E} -> gatherer:in(Gatherer, {error, E}) + catch {error, E} -> gatherer:in(Gatherer, {error, E}); + _:E -> gatherer:in(Gatherer, {error, E}) end, gatherer:finish(Gatherer) end) @@ -633,8 +633,6 @@ validate_vhost_queue_limit(VHost, AddCount, {true, Limit, QueueCount}) -> ErrMsg = rabbit_misc:format(ErrFmt, ErrInfo), exit({vhost_limit_exceeded, ErrMsg}). -atomise_name(N) -> rabbit_data_coercion:to_atom(N). - get_or_missing(K, L) -> case maps:get(K, L, undefined) of undefined -> {key_missing, K}; |
