Skip to content

Commit

Permalink
a little cleanup in gen_cluster
Browse files Browse the repository at this point in the history
  • Loading branch information
auser committed Jul 7, 2010
1 parent cc46fdc commit ea286f9
Showing 1 changed file with 1 addition and 6 deletions.
7 changes: 1 addition & 6 deletions src/gen_cluster.erl
Expand Up @@ -363,12 +363,7 @@ join_cluster(State) ->
cluster_pids(State)),
{ok, State}.

% PUB/SUB
% subscribe through gproc
% subscribe({QueueName, Props}) when is_list(QueueName) -> subscribe({erlang:list_to_atom(QueueName), Props});
% subscribe({QueueName, Props}) ->
% Fun = proplists:get_value(callback, fun unhandled/1, Props),
% gproc:reg({p, l, {QueueName, Fun}}).
% publish through gproc
do_publish(Mod, Msg) ->
lists:foreach(fun(Pid) ->
case catch erlang:send(Pid, {'$gen_cluster', handle_publish, Msg}, [noconnect]) of
Expand Down

0 comments on commit ea286f9

Please sign in to comment.