anchor.diff:      rabbit_log:warning("Topic ~s did not connect locally~n~p~n",
                          [rabbit_misc:rs(XName), E]),
       {stop, {shutdown, restart}, State}.
  -
  -%%----------------------------------------------------------------------------
  -
  -handle_down(Ch, Reason, Ch, State) ->
  -    {stop, {channel_down, Reason}, State}.
   
   %%----------------------------------------------------------------------------
   
  
positive.code: -include_lib("amqp_client/include/amqp_client.hrl").
  
  %% real
  -export([start_conn_ch/4, disposable_channel_call/2, disposable_channel_call/3,
           disposable_connection_call/3, disposable_connection_calls/3,
           ensure_connection_closed/1, handle_down/4]).
  
  %% temp
  -export([connection_error/5]).
  
negative.code: -define(MAX_CONNECTION_CLOSE_TIMEOUT, 10000).
  
  %%----------------------------------------------------------------------------
  
  open_monitor(Params) ->
      case open(Params) of
  