anchor.diff:          true ->     
               {_Schema,Table} = hd(Stmt#statement.tables),
               % ?Debug("fetch complete, switching to tail_mode~p~n", [Opts]), 
  -            case  catch if_call_mfa(false,subscribe,[none,{table,Table,simple}]) of
  +            case  catch if_call_mfa(false,subscribe,[none,{table, Table, detailed}]) of
                   ok ->
                       % ?Debug("Subscribed to table changes ~p~n", [Table]),    
                       {noreply, State#state{fetchCtx=FetchCtx0#fetchCtx{status=tailing}}};
  
positive.code: 
  unsubscribe(Stmt) ->
      {_Schema,Table} = hd(Stmt#statement.tables),
      case catch if_call_mfa(false,unsubscribe,[none,{table,Table,simple}]) of
          ok ->       ok;
          {ok,_} ->   ok;
          Error ->
  
negative.code:             imem_meta:log_to_db(warning,?MODULE,handle_info,[{row, ?eot}],"eot"),
              {noreply, State}
      end;        
  handle_info({mnesia_table_event, {write, _Table, {schema, _TableName, _TableNewProperties}, _OldRecords, _ActivityId}}, State) ->
      % imem_meta:log_to_db(debug,?MODULE,handle_info,[{mnesia_table_event,write, schema}],"tail delete"),
      % ?Debug("received mnesia subscription event ~p ~p ~p~n", [write_schema, _TableName, _TableNewProperties]),
      {noreply, State};
  handle_info({mnesia_table_event,{write,_Table,R0,_OldRecords,_ActivityId}},#state{reply=Sock}=State) ->
      case process_tail_row(R0, State) of
          {[], NewState} -> {noreply, NewState};
          {Result, NewState} ->
              send_reply_to_client(Sock, Result),
              {noreply, NewState}
      end;
  handle_info({mnesia_table_event,{delete, schema, _What, _SchemaInfo, _ActivityId}}, State) ->
      {noreply, State};
  handle_info({mnesia_table_event,{delete, _Table, _What, DelRows, _ActivityId}}, State) ->
      NewState = process_tail_delete_rows(DelRows, State),
      {noreply, NewState};
  handle_info({row, Rows0}, #state{reply=Sock, isSec=IsSec, seco=SKey, fetchCtx=FetchCtx0, statement=Stmt}=State) ->
      #fetchCtx{metarec=MR0,rownum=RowNum,remaining=Rem0,status=Status,filter=FilterFun, opts=Opts}=FetchCtx0,
      % ?LogDebug("received ~p rows (possibly including start and end flags)~n", [length(Rows0)]),
  