anchor.diff:  
   init({InstanceName, FromTimestamp, SubPid}) ->
       link(SubPid),
  +    MRef=monitor(process, SubPid),
       ZList=logmachine:get_zlist(InstanceName, FromTimestamp),
       {ok, #state{instance=InstanceName,
                   zlist=ZList,
                   subscriber=SubPid,
  +                subscriber_mref=MRef,
                   last_from=FromTimestamp,mode=recover}, 1}.
   
  -handle_call(_Request, _From, State) ->
  +handle_call(_Request, _From, #state{}=State) ->
       {reply, unsupported, State}.
   
   handle_cast({Ts, _ }=HistoryEntry, 
  
positive.code:     LastFrom1=send_entries(SubPid, L, LastFrom),
      % Update state with tail zlist and new timestamp
      {noreply, State#state{zlist=ZList1,last_from=LastFrom1}, 1};
  handle_info(_Info, State) ->
      {noreply, State}.
  
  terminate(_Reason, _State) -> ok.
  
negative.code:                    mode=normal}=State) when Ts > LastFrom ->
      LastFrom1=send_entries(SubPid, [HistoryEntry], LastFrom),
      {noreply, State#state{last_from=LastFrom1}};
  handle_cast(_Msg, #state{}=State) ->
      {noreply, State}.
  
  % History pump done, hence enter normal mode (retranslation)
  handle_info(timeout, 
              #state{instance=InstanceName,
                     zlist=[],
  