diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-03-15 11:59:37 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-03-15 11:59:37 +0000 |
| commit | d7181b984247257cf0f52fa86b42129aa8674782 (patch) | |
| tree | b46c0d430a4085b44bcba3b3df0241e56b8eb6a0 | |
| parent | d917bc5cf0a8550f529bf6a4d04b73fe683e8154 (diff) | |
| download | rabbitmq-server-d7181b984247257cf0f52fa86b42129aa8674782.tar.gz | |
Slightly nicer to use a -define().
| -rw-r--r-- | src/rabbit_amqqueue.erl | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index c9fcec58..9b6f14ca 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -42,6 +42,8 @@ -define(MORE_CONSUMER_CREDIT_AFTER, 50). +-define(FAILOVER_WAIT_MILLIS, 100). + %%---------------------------------------------------------------------------- -ifdef(use_specs). @@ -438,7 +440,7 @@ force_event_refresh(QNames) -> lists:member(Pid, FailedPids)], case Failed of [] -> ok; - _ -> timer:sleep(100), + _ -> timer:sleep(?FAILOVER_WAIT_MILLIS), force_event_refresh(Failed) end. |