anchor.diff:      {stop, {unexpected_cast, Msg}, State}.
   
   handle_info(Msg, State) ->
  -    rabbit_log:info("got info msg: ~p~n", [Msg]),
       {stop, {unexpected_info, Msg}, State}.
   
   terminate(_Reason, {not_started, _}) ->
  
positive.code:                 {error, Code, Text}
               end,
      R = rabbit_topic_shard_util:disposable_connection_calls(#amqp_params_direct{}, Methods, ErrFun),
      rabbit_log:info("disposable_connection_calls result: ~p~n", [R]),
      State.
  
  exchange_name(#resource{name = XBin}) -> XBin.
  
negative.code: list_queues(XN)  -> call(XN, list_queues).
  
  start_link(Args) ->
      gen_server2:start_link(?MODULE, Args, [{timeout, infinity}]).
  
  init(#exchange{name = XName} = X) ->
      %% If we are starting up due to a policy change then it's possible
      %% for the exchange to have been deleted before we got here, in which
      %% case it's possible that delete callback would also have been called
  