diff options
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index da4b83fcf7..dec5d50b7e 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -578,9 +578,7 @@ possibly_unblock(Update, ChPid, State = #q{consumers = Consumers}) -> unchanged -> State; {unblocked, Consumers1} -> - State1 = State#q{consumers = Consumers1}, - notify_decorators(State1), - run_message_queue(State1) + run_message_queue(true, State#q{consumers = Consumers1}) end. should_auto_delete(#q{q = #amqqueue{auto_delete = false}}) -> false; |