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 | a099333a6db6f2fcb53435b8640818c9d0b6a838 (patch) | |
| tree | 58ff0b35ef86458e9ab265c3ebabf39359da82c8 /src | |
| parent | 3c6b988542c3e1abebf4128eb528a43e3955bc7c (diff) | |
| download | rabbitmq-server-git-a099333a6db6f2fcb53435b8640818c9d0b6a838.tar.gz | |
cosmetic
Diffstat (limited to 'src')
| -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 6391ebe6ab..d916dccb34 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; |