diff options
| author | Michael Klishin <mklishin@pivotal.io> | 2016-03-23 19:11:23 +0300 |
|---|---|---|
| committer | Michael Klishin <mklishin@pivotal.io> | 2016-03-23 19:11:23 +0300 |
| commit | a9c1bcdb0822118d9e0dece7af3fd3fe8a3cbd8e (patch) | |
| tree | f501fe6472b7194b17849dcdbdf02b9b791e56de | |
| parent | 9f4e9442a453f0dc23078571cc63b69b31c8fdcb (diff) | |
| download | rabbitmq-server-git-a9c1bcdb0822118d9e0dece7af3fd3fe8a3cbd8e.tar.gz | |
Inline, don't reinvent rabbit_misc:get_env/3
| -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, |