anchor.diff:  on_init({tx_tm_rtm_commit, _Client, _ClientsID, _TransLog} = Msg, State) ->
       %% only in tx_tm
       tx_tm = state_get_role(State),
  -    QueuedMessages = state_get_qmsg(State),
  -    NewQueuedMessages = msg_queue:add(QueuedMessages, Msg),
  -    state_set_qmsg(State, NewQueuedMessages);
  +    %% 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
  
positive.code: state_inc_opentxnum(State) -> setelement(7, State, element(7, State) + 1).
  -spec state_dec_opentxnum(state()) -> state().
  state_dec_opentxnum(State) -> setelement(7, State, element(7, State) - 1).
  -spec state_get_qmsg(state()) -> msg_queue:msg_queue().
  state_get_qmsg(State)          -> element(8, State).
  -spec state_set_qmsg(state(), msg_queue:msg_queue()) -> state().
  state_set_qmsg(State, Val)     -> setelement(8, State, Val).
  
  -spec state_subscribe(state(), comm:mypid()) -> state().
  state_subscribe(State, Pid) ->
  
negative.code:         tx_tm ->
              comm:send_local(self(), {get_node_details}),
              State = {_RTMs = [], TableName, Role, LAcceptor, GLLearner,
                       [], 0},
              %% subscribe to id changes
              rm_loop:subscribe(self(), ?MODULE,
                                fun rm_loop:subscribe_dneighbor_change_filter/3,
                                fun ?MODULE:rm_send_update/4, inf),
              gen_component:change_handler(State, on_init);
          _ -> {_RTMs = [], TableName, Role, LAcceptor, GLLearner, [], 0}
      end.
  
  -spec on(comm:message(), state()) -> state().
  