diff options
| author | Michael Klishin <mklishin@pivotal.io> | 2015-05-10 21:04:52 +0300 |
|---|---|---|
| committer | Michael Klishin <mklishin@pivotal.io> | 2015-05-10 21:04:52 +0300 |
| commit | 9a8e7b0a243daa2b3778dbf342a0229f7cfd40f9 (patch) | |
| tree | e15525ee9e76f9e8b86dcb3e85c4f1a93b46c52e | |
| parent | a61069fe9fc5a7232c2492c44ba2367e364db04a (diff) | |
| download | rabbitmq-server-git-9a8e7b0a243daa2b3778dbf342a0229f7cfd40f9.tar.gz | |
Refactor
| -rw-r--r-- | src/rabbit_dead_letter.erl | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/src/rabbit_dead_letter.erl b/src/rabbit_dead_letter.erl index e756d8a011..f013c2e984 100644 --- a/src/rabbit_dead_letter.erl +++ b/src/rabbit_dead_letter.erl @@ -154,12 +154,14 @@ increment_xdeath_event_count(Info) -> end. queue_and_reason_matcher(Q, R) -> - fun({table, Info}) -> - x_death_event_key(Info, <<"queue">>, longstr) =:= Q - andalso x_death_event_key(Info, <<"reason">>, longstr) =:= R; - (Info) when is_list(Info) -> + F = fun(Info) -> x_death_event_key(Info, <<"queue">>, longstr) =:= Q andalso x_death_event_key(Info, <<"reason">>, longstr) =:= R + end, + fun({table, Info}) -> + F(Info); + (Info) when is_list(Info) -> + F(Info) end. per_msg_ttl_header(#'P_basic'{expiration = undefined}) -> |