anchor.diff:  handle(_ProtocolVersion, ping) ->
     pong;
   
  -handle(_ProtocolVersion, #eventmessage{type = Type}) ->
  -  Event = [{type, list_to_atom(Type)}, {user_dn, get(user_id)}, {fuse_id, get(fuse_id)}],
  +handle(_ProtocolVersion, #eventmessage{type = Type, count = Count}) ->
  +  Event = [{type, list_to_atom(Type)}, {user_dn, get(user_id)}, {fuse_id, get(fuse_id)}, {count, Count}],
     handle(1, {event_arrived, Event});
   
   handle(_ProtocolVersion, healthcheck) ->
  
positive.code: register_rm_event_handler() ->
    EventHandler = fun(Event) ->
      ?info("RmEvent Handler"),
      UserDn = proplists:get_value(user_dn, Event),
      FuseId = proplists:get_value(fuse_id, Event),
      case user_logic:quota_exceeded({dn, UserDn}) of
        false -> request_dispatcher:send_to_fuse(FuseId, #atom{value = "write_enabled"}, "communication_protocol");
        _ -> ok
      end
    end,
  
  
negative.code: 
  %% functions for manual tests
  -export([register_mkdir_handler/0, register_mkdir_handler_aggregation/1, register_write_event_handler/1, register_quota_exceeded_handler/0,
           send_mkdir_event/0, delete_file/1, change_quota/2, register_rm_event_handler/0, prepare/2, register_for_stats/1]).
  
  -ifdef(TEST).
  -compile([export_all]).
  