anchor.diff:  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),
  
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.