diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2013-01-03 21:54:35 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2013-01-03 21:54:35 +0000 |
| commit | ea2df79dbe2d66aa73ee39f576f4570d62e33ddc (patch) | |
| tree | cdb0ddc5789a02aa6f5a2f4a4f3d8a71701d5f09 /src | |
| parent | 3f082a2c3bf9292895a8f4c414ecb7a3655afb97 (diff) | |
| download | rabbitmq-server-git-ea2df79dbe2d66aa73ee39f576f4570d62e33ddc.tar.gz | |
fix bug found by dialyzer
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 326065d13d..6b065b968d 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -1151,8 +1151,8 @@ handle_call(sync_mirrors, _From, S = fun(BQSN) -> State#q{backing_queue_state = BQSN} end, case BQ:depth(BQS) - BQ:len(BQS) of 0 -> case rabbit_mirror_queue_master:sync_mirrors(BQS) of - {shutdown, Reason, BQS1} -> {stop, Reason, S(BQS1)}; - {Result, BQS1} -> reply(Result, S(BQS1)) + {ok, BQS1} -> reply(ok, S(BQS1)); + {stop, Reason, BQS1} -> {stop, Reason, S(BQS1)} end; _ -> reply({error, pending_acks}, State) end; |