anchor.diff:      Client = Payload#payload_remote.client,
       Source = Label#label.sender,
       NewLabel = create_label(remote_reply, {Bucket, routing}, TimeStamp, {Partition, node()}, MyId, #payload_reply{value=Value, to=Source, client=Client}),
  -    saturn_leaf_producer:new_label(MyId, NewLabel, Partition),
  +    saturn_leaf_producer:new_label(MyId, NewLabel, Partition, false),
       {reply, ok, S0#state{max_ts=TimeStamp, last_label=NewLabel}};
   
  -handle_command({heartbeat, MyId}, _From, S0=#state{partition=Partition, max_ts=MaxTS0}) ->
  +handle_command(heartbeat, _From, S0=#state{partition=Partition, max_ts=MaxTS0, myid=MyId}) ->
       Clock = max(saturn_utilities:now_microsec(), MaxTS0+1),
       saturn_leaf_producer:partition_heartbeat(MyId, Partition, Clock),
  -    riak_core_vnode:send_command_after(?HEARTBEAT_FREQ, {heartbeat, MyId}),
  -    {noreply, S0#state{myid=MyId, max_ts=Clock}};
  +    riak_core_vnode:send_command_after(?HEARTBEAT_FREQ, heartbeat),
  +    {noreply, S0#state{max_ts=Clock}};
   
   handle_command(last_label, _Sender, S0=#state{last_label=LastLabel}) ->
       {reply, {ok, LastLabel}, S0};
  
positive.code: terminate(_Reason, _State) ->
      ok.
  
  check_myid(S0) ->
      Value = riak_core_metadata:get(?MYIDPREFIX, ?MYIDKEY),
      case Value of
          undefined ->
              timer:sleep(100),
              check_myid(S0);
          MyId ->
              groups_manager_serv:set_myid(MyId),
              S0#state{myid=MyId}
      end.
      
  create_label(Operation, BKey, TimeStamp, Node, Id, Payload) ->
      #label{operation=Operation,
             bkey=BKey,
  
negative.code:             false
      end.
  
  handle_command({check_tables_ready}, _Sender, SD0) ->
      {reply, true, SD0};
  
  handle_command({init_proxy, MyId}, _From, S0) ->
      groups_manager_serv:set_myid(MyId),
      {reply, ok, S0#state{myid=MyId}};
  
  handle_command({read, BKey, Clock}, From, S0=#state{myid=MyId, max_ts=MaxTS0, partition=Partition, connector=Connector}) ->
      case groups_manager_serv:do_replicate(BKey) of
  