diff options
| -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 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. |