anchor.diff:      ?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 = couch_config:register(
  -        fun("replicator", "max_replication_retry_count", V) ->
  -            ok = gen_server:cast(Server, {set_max_retries, retries_value(V)})
  -        end
  -    ),
  +    ok = config:listen_for_changes(?MODULE, Server),
       ScanPid = spawn_link(fun() -> scan_all_dbs(Server) end),
       {ok, #state{
           db_notifier = db_update_notifier(),
  
positive.code:     end.
  
  
  init(_) ->
      process_flag(trap_exit, true),
      net_kernel:monitor_nodes(true),
  
negative.code: % gen_server callbacks
  -export([start_link/0, init/1, handle_call/3, handle_info/2, handle_cast/2]).
  -export([code_change/3, terminate/2]).
  
  % config_listener callback
  -export([handle_config_change/5]).
  
  -include_lib("couch/include/couch_db.hrl").
  -include("couch_replicator.hrl").
  