anchor.diff:          [Loop | StartPids]),
       true = ets:delete(?REP_TO_STATE),
       true = ets:delete(?DOC_TO_REP),
  -    couch_db_update_notifier:stop(Notifier).
  +    couch_replication_notifier:stop(RepNotifier),
  +    couch_db_update_notifier:stop(DbNotifier).
   
   
   code_change(_OldVsn, State, _Extra) ->
  
positive.code:     rep,
      starting,
      retries_left,
      max_retries
  }).
  
  -import(couch_replicator_utils, [
  
negative.code:             maybe_start_replication(State, DocId, JsonRepDoc);
          <<"triggered">> ->
              maybe_start_replication(State, DocId, JsonRepDoc);
          <<"completed">> ->
              replication_complete(DocId),
              State;
          <<"error">> ->
              replication_error(State, DocId)
          end
      end.
  
  