anchor.diff:    WriteEvent2 = #write_event{user_id = "1235", ans_pid = self()},
     WriteEvent3 = #write_event{user_id = "1334", ans_pid = self()},
     WriteEvent4 = #write_event{user_id = "1335", ans_pid = self()},
  +  WriteEvent5 = #write_event{user_id = "1236", ans_pid = self()},
     WriteEvents = [WriteEvent1, WriteEvent2, WriteEvent3, WriteEvent4],
     SendWriteEvent = fun (Event) -> send_event(Event, CCM) end,
   
  
positive.code: 
  -export([all/0, init_per_testcase/2, end_per_testcase/2]).
  %all() -> [test_event_subscription, test_event_aggregation, test_dispatching].
  all() -> [test_dispatching].
  
  -define(assert_received(ResponsePattern), receive
                                              ResponsePattern -> ok
  
negative.code:   end,
  
    EventHandler = fun(#write_event{user_id = UserId, ans_pid = AnsPid}) ->
  %%     ?info("EventHandler ~p", [node(self())]),
      AnsPid ! {ok, ProcessingMethod, self()}
    end,
  
  