summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2014-05-12 16:35:50 +0100
committerSimon MacMullen <simon@rabbitmq.com>2014-05-12 16:35:50 +0100
commite6bc16a40c80ac7f0833a39e76199fe7e4176ac7 (patch)
treedf2f3c316f00988e08c30e6479c409f8636175a3
parent10c2f19d0576407b0148d3218d2d2fd66ca6c64e (diff)
downloadrabbitmq-server-bug26173.tar.gz
Fix broken invocation.bug26173
-rw-r--r--src/gm.erl3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/gm.erl b/src/gm.erl
index 0c0ac349..fb59b9cb 100644
--- a/src/gm.erl
+++ b/src/gm.erl
@@ -1036,7 +1036,8 @@ join_group(Self, GroupName, #gm_group { members = Members } = Group, TxnFun) ->
case lists:filter(fun is_member_alive/1, Members) of
[] ->
join_group(Self, GroupName,
- prune_or_create_group(Self, GroupName, TxnFun));
+ prune_or_create_group(Self, GroupName, TxnFun),
+ TxnFun);
Alive ->
Left = lists:nth(random:uniform(length(Alive)), Alive),
Handler =