diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-12-29 05:00:27 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-12-29 05:00:27 +0000 |
| commit | 55ec7b64c67491976ed6be90dc449e29f756da52 (patch) | |
| tree | 4837e0c9cf98c527134202f1c7fbee109f17ac72 /src | |
| parent | 5f3fed85835ad73689d7960c148485a06e964a63 (diff) | |
| download | rabbitmq-server-git-55ec7b64c67491976ed6be90dc449e29f756da52.tar.gz | |
cosmetic
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 03bcdf43f9..781546af88 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -791,12 +791,9 @@ stop(State) -> stop(undefined, noreply, State). stop(From, Reply, State = #q{unconfirmed = UC}) -> case {dtree:is_empty(UC), Reply} of - {true, noreply} -> - {stop, normal, State}; - {true, _} -> - {stop, normal, Reply, State}; - {false, _} -> - noreply(State#q{delayed_stop = {From, Reply}}) + {true, noreply} -> {stop, normal, State}; + {true, _} -> {stop, normal, Reply, State}; + {false, _} -> noreply(State#q{delayed_stop = {From, Reply}}) end. cleanup_after_confirm(AckTags, State = #q{delayed_stop = DS, |