diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2014-01-08 09:43:20 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2014-01-08 09:43:20 +0000 |
| commit | 13e10b7d36fb77d164f4b4b6744c9ee948c686dc (patch) | |
| tree | 4871d8e4d93427203fea35ee4636dffc27f06d68 | |
| parent | cc5a62e3beab33e4badaff3595e9a696500c21ed (diff) | |
| download | rabbitmq-server-git-13e10b7d36fb77d164f4b4b6744c9ee948c686dc.tar.gz | |
simpler and more efficient
| -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; |