anchor.diff:  -include_lib("amqp_client/include/amqp_client.hrl").
   
   %% real
  --export([start_conn_ch/4, disposable_channel_call/2, disposable_channel_call/3,
  +-export([disposable_channel_call/2, disposable_channel_call/3,
            disposable_connection_call/3, disposable_connection_calls/3,
  -         ensure_connection_closed/1, handle_down/4]).
  +         ensure_connection_closed/1]).
   
   %% temp
   -export([connection_error/5]).
  
positive.code:     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}.
  
  %%----------------------------------------------------------------------------
  
  
negative.code: -define(MAX_CONNECTION_CLOSE_TIMEOUT, 10000).
  
  %%----------------------------------------------------------------------------
  
  open_monitor(Params) ->
      case open(Params) of
  