diff options
| -rw-r--r-- | src/rabbit_mirror_queue_master.erl | 9 |
1 files changed, 1 insertions, 8 deletions
diff --git a/src/rabbit_mirror_queue_master.erl b/src/rabbit_mirror_queue_master.erl index e7afe88483..e447e9de82 100644 --- a/src/rabbit_mirror_queue_master.erl +++ b/src/rabbit_mirror_queue_master.erl @@ -132,14 +132,7 @@ init_with_existing_bq(Q = #amqqueue{name = QName}, BQ, BQS) -> seen_status = dict:new(), confirmed = [], known_senders = sets:new(), - wait_timeout = get_slave_wait_timeout() }. - -get_slave_wait_timeout() -> - case application:get_env(rabbit, slave_wait_timeout) of - {ok, T} -> T; - undefined -> 15000 - end. - + wait_timeout = rabbit_misc:get_env(rabbit, slave_wait_timeout, 15000) }. stop_mirroring(State = #state { coordinator = CPid, backing_queue = BQ, |