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: 
    receive
      ok -> ok
    after 100 ->
      ?assert(false)
    end,
  
  
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) ->
  