diff options
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 94cfa619..6c8b4bcd 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -325,7 +325,7 @@ terminate_shutdown(Fun, State) -> QName = qname(State), notify_decorators(shutdown, [], State), [emit_consumer_deleted(Ch, CTag, QName) || - {Ch, CTag, _} <- consumers(State1)], + {Ch, CTag, _, _} <- consumers(State1)], State1#q{backing_queue_state = Fun(BQS)} end. |