diff options
| author | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-08-23 12:30:13 +0100 |
|---|---|---|
| committer | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-08-23 12:30:13 +0100 |
| commit | 491c6014e6a5ded6a96ed5a0f4b01a1644b668ef (patch) | |
| tree | 5968726155887e7177cece3dde96c66a51080cc6 | |
| parent | 602437bd972b207ae4bc97358104f60dc4248238 (diff) | |
| download | rabbitmq-server-bug25112.tar.gz | |
non-zero timeout when idle for the slave as wellbug25112
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 4e0eb2a6..d82e6ef3 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -577,9 +577,9 @@ next_state(State = #state{backing_queue = BQ, backing_queue_state = BQS}) -> confirm_messages(MsgIds, State #state { backing_queue_state = BQS1 })), case BQ:needs_timeout(BQS1) of - false -> {stop_sync_timer(State1), hibernate}; - idle -> {stop_sync_timer(State1), 0 }; - timed -> {ensure_sync_timer(State1), 0 } + false -> {stop_sync_timer(State1), hibernate }; + idle -> {stop_sync_timer(State1), ?SYNC_INTERVAL}; + timed -> {ensure_sync_timer(State1), 0 } end. backing_queue_timeout(State = #state { backing_queue = BQ }) -> |