anchor.diff:  
   handle_info({'DOWN', _Ref, _, _, _}, State) ->
       % From a db monitor created by a replication process. Ignore.
  +    {noreply, State};
  +
  +handle_info({gen_event_EXIT, {config_listener, ?MODULE}, _Reason}, State) ->
  +    erlang:send_after(5000, self(), restart_config_listener),
  +    {noreply, State};
  +
  +handle_info(restart_config_listener, State) ->
  +    ok = config:listen_for_changes(?MODULE, self()),
       {noreply, State};
   
   handle_info(Msg, State) ->
  
positive.code:     end.
  
  
  init(_) ->
      process_flag(trap_exit, true),
      net_kernel:monitor_nodes(true),
  
negative.code: 
  -module(couch_replicator_manager).
  -behaviour(gen_server).
  -behaviour(config_listener).
  
  % public API
  -export([replication_started/1, replication_completed/2, replication_error/2]).
  