anchor.diff:    subscribe_for_write_events(CCM, standard),
     send_event(WriteEvent, CCM),
     ?assert_received({ok, standard, _}),
  +  assert_nothing_received(CCM),
   
     subscribe_for_write_events(CCM, tree),
     send_event(WriteEvent, CCM),
  
positive.code:   Res = lists:append([{nodes, NodesUp}, {assertions, Assertions}], Config),
  
    ?assertEqual(ok, rpc:call(CCM, ?MODULE, ccm_code1, [])),
    timer:sleep(500),
    RunWorkerCode = fun(Node) ->
      ?assertEqual(ok, rpc:call(Node, ?MODULE, worker_code, []))
    end,
    lists:foreach(RunWorkerCode, WorkerNodes),
    timer:sleep(1000),
  
    {Workers, _} = gen_server:call({global, ?CCM}, get_workers),
  
  
negative.code:   lists:foreach(fun(Node) -> StartAdditionalWorker(Node, cluster_rengine) end, NodesUp),
    StartAdditionalWorker(CCM, dao),
  
    nodes_manager:wait_for_cluster_init(length(NodesUp) - 1),
    Res.
  
  end_per_testcase(distributed_test, Config) ->
  