diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-03-05 17:47:48 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-03-05 17:47:48 +0000 |
| commit | 525e498c466112ab9a2dca18e74173bda61ef90c (patch) | |
| tree | 3e502a3b7a12fcb99fd21cdffcc63cdf258ccab9 /src | |
| parent | ac114c61b2bb8585c058a048adf2ae1ffc6a37ab (diff) | |
| download | rabbitmq-server-git-525e498c466112ab9a2dca18e74173bda61ef90c.tar.gz | |
cosmetic, plus report Pid instead of {ok, Pid}
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_misc.erl | 13 |
1 files changed, 6 insertions, 7 deletions
diff --git a/src/rabbit_mirror_queue_misc.erl b/src/rabbit_mirror_queue_misc.erl index db7d8eccec..180677fe55 100644 --- a/src/rabbit_mirror_queue_misc.erl +++ b/src/rabbit_mirror_queue_misc.erl @@ -134,18 +134,17 @@ add_mirror(Queue, MirrorNode) -> Queue, fun (#amqqueue { name = Name, pid = QPid, slave_pids = SPids } = Q) -> case [Pid || Pid <- [QPid | SPids], node(Pid) =:= MirrorNode] of - [] -> Result = rabbit_mirror_queue_slave_sup:start_child( - MirrorNode, [Q]), - case Result of + [] -> case rabbit_mirror_queue_slave_sup:start_child( + MirrorNode, [Q]) of {ok, undefined} -> %% Already running ok; - {ok, _Pid} -> + {ok, SPid} -> rabbit_log:info( "Adding mirror of ~s on node ~p: ~p~n", - [rabbit_misc:rs(Name), MirrorNode, Result]), + [rabbit_misc:rs(Name), MirrorNode, SPid]), ok; - _ -> - Result + Other -> + Other end; [_] -> {error, {queue_already_mirrored_on_node, MirrorNode}} end |