anchor.diff:      case lists:keymember(unknown, 2, NewRTMs) of %% filled all entries?
           false ->
               rtms_of_same_dht_node(NewRTMs),
  -            msg_queue:send(state_get_qmsg(State)),
  -            NewState = state_set_qmsg(State, []),
  -            gen_component:change_handler(
  -              state_set_RTMs(NewState, NewRTMs), on);
  +            gen_component:change_handler(state_set_RTMs(State, NewRTMs), on);
           _ -> state_set_RTMs(State, NewRTMs)
       end;
   
  
positive.code:      GLocalLearner  :: comm:mypid(),
       %% reference counting on subscriptions inside RTMs
       Subs           :: [{comm:mypid(), non_neg_integer()}],
       OpenTxNum      :: non_neg_integer(),
       QueuedMessages :: msg_queue:msg_queue()}.
  
  %% initialize: return initial state.
  -spec init([]) -> state() | {'$gen_component', [{on_handler, on_init},...],
  
negative.code: on_init({tx_tm_rtm_commit, _Client, _ClientsID, _TransLog} = Msg, State) ->
      %% only in tx_tm
      tx_tm = state_get_role(State),
      %% forward request to a node which is ready to serve requests
      DHTNode = pid_groups:get_my(dht_node),
      %% there, redirect message to tx_tm
      RedirectMsg = {send_to_group_member, tx_tm, Msg},
      comm:send_local(DHTNode, {lookup_aux, ?RT:get_random_node_id(), 0, RedirectMsg}),
      State;
  
  on_init({crash, _Pid} = Msg, State) ->
      %% only in tx_tm
  