diff options
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 0c25cf3a5f..9a5cdfb1f4 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -91,8 +91,10 @@ start_link(Q) -> {ok, Pid} = gen_server2:start_link(?MODULE, [], []), - gen_server2:call(Pid, {init, Q}, infinity), - {ok, Pid}. + case gen_server2:call(Pid, {init, Q}, infinity) of + ok -> {ok, Pid}; + existing -> ignore + end. set_maximum_since_use(QPid, Age) -> gen_server2:cast(QPid, {set_maximum_since_use, Age}). |