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 | bbd9a1d85c1a5ce86b14cdea86f8926cff647c00 (patch) | |
| tree | 5968726155887e7177cece3dde96c66a51080cc6 | |
| parent | de787513d717b673e03e182db1c9a669babefe8a (diff) | |
| download | rabbitmq-server-git-bbd9a1d85c1a5ce86b14cdea86f8926cff647c00.tar.gz | |
non-zero timeout when idle for the slave as well
| -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 4e0eb2a671..d82e6ef397 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 }) -> |