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 | 46d572342e6b1af9944fc170bebf92ca7a86f9f4 (patch) | |
| tree | 4837e0c9cf98c527134202f1c7fbee109f17ac72 | |
| parent | f0fe8744f80e98980594470eb03309d6611f50c5 (diff) | |
| download | rabbitmq-server-46d572342e6b1af9944fc170bebf92ca7a86f9f4.tar.gz | |
cosmetic
| -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 03bcdf43..781546af 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, |