anchor.diff:  
   handle_info(shutdown, State) ->
       {stop, shutdown, State};
  +
  +handle_info(restart_config_listener, State) ->
  +    ok = config:listen_for_changes(?MODULE, nil),
  +    {noreply, State};
   
   handle_info(Msg, State) ->
       couch_log:error("Replication manager received unexpected message ~p", [Msg]),
  
positive.code: -define(CTX, {user_ctx, #user_ctx{roles=[<<"_admin">>, <<"_replicator">>]}}).
  
  -define(replace(L, K, V), lists:keystore(K, 1, L, {K, V})).
  
  -record(rep_state, {
      rep,
  
negative.code:     ?REP_TO_STATE = ets:new(?REP_TO_STATE, [named_table, set, public]),
      ?DB_TO_SEQ = ets:new(?DB_TO_SEQ, [named_table, set, public]),
      Server = self(),
      ok = config:listen_for_changes(?MODULE, nil),
      Epoch = make_ref(),
      ScanPid = spawn_link(fun() -> scan_all_dbs(Server) end),
      % Automatically start node local changes feed loop
  