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: %% -include_lib("kernel/include/inet.hrl").
  -include_lib("amqp_client/include/amqp_client.hrl").
  
  -export([go/0, ensure_shard/1, remove_shard/1, list_queues/1]).
  
  -export([start_link/1]).
  
  
negative.code:                 {error, Code, Text}
               end,
      _R = rabbit_topic_shard_util:disposable_connection_calls(#amqp_params_direct{}, Methods, ErrFun),
      State.