anchor.diff:      Epoch = make_ref(),
       ScanPid = spawn_link(fun() -> scan_all_dbs(Server) end),
       % Automatically start node local changes feed loop
  -    ensure_rep_db_exists(<<"_replicator">>),
  -    Pid = start_changes_reader(<<"_replicator">>, 0, Epoch),
  +    ensure_rep_db_exists(?REPLICATOR_DB),
  +    Pid = start_changes_reader(?REPLICATOR_DB, 0, Epoch),
       {ok, #state{
           event_listener = start_event_listener(),
           scan_pid = ScanPid,
  
positive.code: -define(AVG_ERROR_DELAY_MSEC, 100).
  -define(MAX_ERROR_DELAY_MSEC, 60000).
  -define(OWNER, <<"owner">>).
  
  -define(DB_TO_SEQ, db_to_seq).
  -define(CTX, {user_ctx, #user_ctx{roles=[<<"_admin">>, <<"_replicator">>]}}).
  
negative.code: 	end, ok).
  
  is_replicator_db(DbName) ->
      ?REPLICATOR_DB =:= couch_db:dbname_suffix(DbName).
  
  get_json_value(Key, Props) ->
      get_json_value(Key, Props, undefined).
  