summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2012-03-15 11:59:37 +0000
committerSimon MacMullen <simon@rabbitmq.com>2012-03-15 11:59:37 +0000
commit44ec6f212e61cad22e19e60528116b7f441a3a3c (patch)
treeb46c0d430a4085b44bcba3b3df0241e56b8eb6a0
parenta66c1d8e5fff92f2466ba37b7aa0b55d70663cf3 (diff)
downloadrabbitmq-server-git-44ec6f212e61cad22e19e60528116b7f441a3a3c.tar.gz
Slightly nicer to use a -define().
-rw-r--r--src/rabbit_amqqueue.erl4
1 files changed, 3 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl
index c9fcec583e..9b6f14ca06 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.