diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2017-09-07 13:59:30 -0700 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2017-09-07 13:59:30 -0700 |
| commit | d901ecbfacde2f37b5b8a68aa8ca563f286afbea (patch) | |
| tree | 9144fce04cdefb113b5eb8d32fb2f52f9b65f0e8 /src | |
| parent | 96cd56a9d040ffeeeb62c95b84826c1f021a3ebc (diff) | |
| download | rabbitmq-server-git-d901ecbfacde2f37b5b8a68aa8ca563f286afbea.tar.gz | |
Handle cases where the headers table is undefined
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_dead_letter.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/rabbit_dead_letter.erl b/src/rabbit_dead_letter.erl index d185e95edd..5ec1da0e34 100644 --- a/src/rabbit_dead_letter.erl +++ b/src/rabbit_dead_letter.erl @@ -112,6 +112,8 @@ group_by_queue_and_reason(Tables) -> end, {sets:new(), []}, Tables), Grouped. +update_x_death_header(Info, undefined) -> + update_x_death_header(Info, []); update_x_death_header(Info, Headers) -> X = x_death_event_key(Info, <<"exchange">>), Q = x_death_event_key(Info, <<"queue">>), |
