anchor.diff:      {ok, Pid}.
   
   
  +db_update_notifier() ->
  +    Server = self(),
  +    {ok, Notifier} = couch_db_update_notifier:start_link(
  +        fun({created, DbName}) ->
  +            case ?l2b(couch_config:get("replicator", "db", "_replicator")) of
  +            DbName ->
  +                ok = gen_server:cast(Server, rep_db_created);
  +            _ ->
  +                ok
  +            end;
  +        (_) ->
  +            ok
  +        end
  +    ),
  +    Notifier.
  +
  +
   changes_processor(ChangesQueue) ->
       Pid = spawn_link(
           fun() ->
  
positive.code: -define(REP_ID_TO_DOC_ID_MAP, rep_id_to_rep_doc_id).
  
  -record(state, {
      changes_feed_loop,
      changes_queue,
      changes_processor
  }).
  
  
  
negative.code:     [] ->
          none
      end.
  
  stop_all_replications() ->
      ets:foldl(
          fun({_, RepId}, _) -> couch_rep:end_replication(RepId) end,
          ok,
          ?DOC_TO_REP_ID_MAP
      ),
      true = ets:delete_all_objects(?REP_ID_TO_DOC_ID_MAP),
      true = ets:delete_all_objects(?DOC_TO_REP_ID_MAP).
  