diff options
| author | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-02-22 13:08:28 +0000 |
|---|---|---|
| committer | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-02-22 13:08:28 +0000 |
| commit | 10394f9c082b2c2e8a9ff733b4240bd86c3e993e (patch) | |
| tree | 1e5a424ad1c0cf01059298e740d17004ca579124 /src | |
| parent | 17c67eaf445372bc4549169e024fcca93d3589cb (diff) | |
| download | rabbitmq-server-git-10394f9c082b2c2e8a9ff733b4240bd86c3e993e.tar.gz | |
Using SYNC_INTERVAL for the idle timeout as well.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 34efbde84d..3032b3171f 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -23,7 +23,6 @@ -define(UNSENT_MESSAGE_LIMIT, 200). -define(SYNC_INTERVAL, 25). %% milliseconds -define(RAM_DURATION_UPDATE_INTERVAL, 5000). --define(IDLE_TIMEOUT, 10). -define(BASE_MESSAGE_PROPERTIES, #message_properties{expiry = undefined, needs_confirming = false}). @@ -251,9 +250,9 @@ next_state(State = #q{backing_queue = BQ, backing_queue_state = BQS}) -> confirm_messages(MsgIds, State#q{ backing_queue_state = BQS1}))), case BQ:needs_timeout(BQS1) of - false -> {stop_sync_timer(State1), hibernate }; - idle -> {stop_sync_timer(State1), ?IDLE_TIMEOUT}; - 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_module(#amqqueue{arguments = Args}) -> |