diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-10-01 22:20:24 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-10-01 22:20:24 +0100 |
| commit | 7f35eab89ef91db53de9c76195b00b03e69c9d37 (patch) | |
| tree | 8533940dff757ded3b561784eff1bddb0a9a9e70 /src | |
| parent | 76ae76fcf3a2e939c8aef7d01bc7ecc43a92100a (diff) | |
| download | rabbitmq-server-git-7f35eab89ef91db53de9c76195b00b03e69c9d37.tar.gz | |
cosmetic
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_master.erl | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/rabbit_mirror_queue_master.erl b/src/rabbit_mirror_queue_master.erl index 71d316f339..48650206d8 100644 --- a/src/rabbit_mirror_queue_master.erl +++ b/src/rabbit_mirror_queue_master.erl @@ -131,8 +131,7 @@ delete_and_terminate(Reason, State = #state { gm = GM, node(Pid) =/= node()], MRefs = [erlang:monitor(process, S) || S <- Slaves], ok = gm:broadcast(GM, {delete_and_terminate, Reason}), - [receive {'DOWN', MRef, process, _Pid, _Info} -> ok end || - MRef <- MRefs], + [receive {'DOWN', MRef, process, _Pid, _Info} -> ok end || MRef <- MRefs], ok = gm:forget_group(proplists:get_value(group_name, Info)), State #state { backing_queue_state = BQ:delete_and_terminate(Reason, BQS), set_delivered = 0 }. |