diff options
| -rw-r--r-- | src/gm.erl | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/gm.erl b/src/gm.erl index 17aca83032..d1bd80b907 100644 --- a/src/gm.erl +++ b/src/gm.erl @@ -515,7 +515,7 @@ group_members(Server) -> init([GroupName, Module, Args]) -> {MegaSecs, Secs, MicroSecs} = now(), random:seed(MegaSecs, Secs, MicroSecs), - Self = {rabbit_guid:guid(), self()}, + Self = make_member(self()), gen_server2:cast(self(), join), {ok, #state { self = Self, left = {Self, undefined}, @@ -1241,6 +1241,8 @@ prepare_members_state(MembersState) -> build_members_state(MembersStateList) -> ?DICT:from_list(MembersStateList). +make_member(Pid) -> {rabbit_guid:guid(), Pid}. + get_pid({_Guid, Pid}) -> Pid. get_pids(Ids) -> [Pid || {_Guid, Pid} <- Ids]. |