diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-02-01 11:17:57 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-02-01 11:17:57 +0000 |
| commit | 634556a6ddf452084652137df1a3247b051b2681 (patch) | |
| tree | 90d8b36ab0b420517124a9c87e48373eb35853f6 | |
| parent | 2110fe86d6082c6e23e0e7e4bbe1b6be0dc361b1 (diff) | |
| download | rabbitmq-server-git-634556a6ddf452084652137df1a3247b051b2681.tar.gz | |
Let's pay attention to whether we actually started or not.
| -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}). |