diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2014-01-09 11:32:08 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2014-01-09 11:32:08 +0000 |
| commit | 84016d39416c8b5b08783cdbf4fbbdaacdb82aeb (patch) | |
| tree | 58ff0b35ef86458e9ab265c3ebabf39359da82c8 | |
| parent | 63d458eb9a17092504b10c659ba44361514378bc (diff) | |
| download | rabbitmq-server-84016d39416c8b5b08783cdbf4fbbdaacdb82aeb.tar.gz | |
cosmetic
| -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 6391ebe6..d916dccb 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; |