anchor.diff:  
   % public API
   -export([replication_started/1, replication_completed/2, replication_error/2]).
  +-export([owner/1]).
   
   -export([before_doc_update/2, after_doc_read/2]).
   
  
positive.code:         live = Live
      }}.
  
  
  handle_call({rep_db_update, DbName, {ChangeProps} = Change}, _From, State) ->
      NewState = try
  
negative.code:     {_, true} ->
          rep_doc_deleted(DbName, DocId),
          State;
      {Owner, false} when Owner /= node() ->
          couch_log:notice("Not starting '~s' as owner is ~s.", [DocId, Owner]),
          State;
      {_Owner, false} ->
          couch_log:notice("Maybe starting '~s' as I'm the owner", [DocId]),
          case get_json_value(<<"_replication_state">>, RepProps) of
          undefined ->
              maybe_start_replication(State, DbName, DocId, JsonRepDoc);
  