diff options
| -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}) -> |