anchor.diff:    end,
     subscribe_for_write_events(CCM, tree, EventHandler2),
     send_event(WriteEvent, CCM),
  -  % from my observations it takes about 200ms until disp map fun is registered in cluster_manager
  -  timer:sleep(900),
  -
  +
  +  % this time there are two handler registered
     ?assert_received({ok, standard, _}),
     ?assert_received({ok, tree, _}, 3000),
     assert_nothing_received(CCM).
  
positive.code: 
    timer:sleep(800).
  
  
  subscribe_for_events(EventType, Node, EventHandler) ->
    EventItem = #event_handler_item{processing_method = standard, handler_fun = EventHandler},
    gen_server:call({?Dispatcher_Name, Node}, {rule_manager, 1, self(), {add_event_handler, {EventType, EventItem}}}),
  
    receive
      ok -> ok
    after 400 ->
      ?assert(false)
    end,
  
    timer:sleep(800).
  
  
  repeat(N, F) -> for(1, N, F).
  for(N, N, F) -> [F()];
  for(I, N, F) -> [F() | for(I + 1, N, F)].
  
negative.code:   WriteEvent = #write_event{user_id = "1234", ans_pid = self()},
  
    repeat(3, fun() -> send_event(WriteEvent, CCM) end),
    assert_nothing_received(CCM),
  
    send_event(WriteEvent, CCM),
  