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 | 1fa503c3766865a705df57cf1e27adb5ec84846f (patch) | |
| tree | 4871d8e4d93427203fea35ee4636dffc27f06d68 | |
| parent | a10df566f0632480665385b023ae6486d5e1f723 (diff) | |
| download | rabbitmq-server-1fa503c3766865a705df57cf1e27adb5ec84846f.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 da4b83fc..dec5d50b 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; |