diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-01-09 13:46:25 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-01-09 13:46:25 +0000 |
| commit | 5ee0a3b8b57aca3f34c39bc9d824fa2f4b716ef5 (patch) | |
| tree | 904fd7419ec985989d6fa9efea6af3e3db1c0e9a /src/rabbit_amqqueue_process.erl | |
| parent | f0ceca7de46e4d70ec74020fff48dded3096c09e (diff) | |
| parent | 84016d39416c8b5b08783cdbf4fbbdaacdb82aeb (diff) | |
| download | rabbitmq-server-5ee0a3b8b57aca3f34c39bc9d824fa2f4b716ef5.tar.gz | |
Merge bug25951
Diffstat (limited to 'src/rabbit_amqqueue_process.erl')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index bd258ecf..c75565d3 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -575,10 +575,9 @@ requeue(AckTags, ChPid, State) -> possibly_unblock(Update, ChPid, State = #q{consumers = Consumers}) -> case rabbit_queue_consumers:possibly_unblock(Update, ChPid, Consumers) of - unchanged -> - State; - {unblocked, Consumers1} -> - run_message_queue(true, State#q{consumers = Consumers1}) + unchanged -> State; + {unblocked, Consumers1} -> State1 = State#q{consumers = Consumers1}, + run_message_queue(true, State1) end. should_auto_delete(#q{q = #amqqueue{auto_delete = false}}) -> false; |