anchor.diff:  all() ->
       pg2_fixed:create(rabbit_topic_shards),
       pg2_fixed:get_members(rabbit_topic_shards).
  -
  -x(XName) ->
  -    pg2_fixed:create({rabbit_topic_shard, XName}),
  -    pg2_fixed:get_members({rabbit_topic_shard, XName}).
   
   %%----------------------------------------------------------------------------
   
  
positive.code: code_change(_OldVsn, State, _Extra) ->
      {ok, State}.
  
  
  call(XName, Msg) -> [gen_server2:call(Pid, Msg, infinity) || Pid <- x(XName)].
  cast(Msg)        -> [gen_server2:cast(Pid, Msg) || Pid <- all()].
  cast(XName, Msg) -> [gen_server2:cast(Pid, Msg) || Pid <- x(XName)].
  
  join(Name) ->
      pg2_fixed:create(Name),
  
negative.code: %% -include_lib("kernel/include/inet.hrl").
  -include_lib("amqp_client/include/amqp_client.hrl").
  
  -export([go/0]).
  
  -export([start_link/1]).
  
  