anchor.diff:  %% central_logger subscribing and log stream
   
   logging_test(Config) ->
  +    nodes_manager:check_start_assertions(Config),
  +
       NodesUp = ?config(nodes, Config),
       [CCM, W1, W2, W3, W4] = NodesUp,
   
       % Init cluster
       gen_server:cast({?Node_Manager_Name, CCM}, do_heart_beat),
       gen_server:cast({global, ?CCM}, {set_monitoring, on}),
  -    test_utils:wait_for_cluster_cast(),
  -    test_utils:wait_for_nodes_registration(length(NodesUp) - 1),
  +    nodes_manager:wait_for_cluster_cast(),
  +    nodes_manager:wait_for_nodes_registration(length(NodesUp) - 1),
       gen_server:cast({global, ?CCM}, init_cluster),
  -    test_utils:wait_for_cluster_init(),
  +    nodes_manager:wait_for_cluster_init(),
   
       % Subscribe for log stream
       Pid = self(),
  
positive.code: %% ====================================================================
  
  init_per_testcase(logging_test, Config) ->
      ?INIT_CODE_PATH, ?CLEAN_TEST_DIRS,
      test_node_starter:start_deps_for_tester_node(),
  
      Nodes = test_node_starter:start_test_nodes(5),
      [CCM | _] = Nodes,
  
      test_node_starter:start_app_on_nodes(?APP_Name, ?VEIL_DEPS, Nodes,
          [[{node_type, ccm},
              {dispatcher_port, 5055},
              {ccm_nodes, [CCM]},
              {dns_port, 1308}, {control_panel_port, 2308}, {control_panel_redirect_port, 1354}, {rest_port, 3308}, {heart_beat, 1}, {nif_prefix, './'}, {ca_dir, './cacerts/'}],
              [{node_type, worker},
                  {dispatcher_port, 5056},
                  {ccm_nodes, [CCM]},
                  {dns_port, 1309}, {control_panel_port, 2309}, {control_panel_redirect_port, 1355}, {rest_port, 3309}, {heart_beat, 1}, {nif_prefix, './'}, {ca_dir, './cacerts/'}],
              [{node_type, worker},
                  {dispatcher_port, 5057},
                  {ccm_nodes, [CCM]},
                  {dns_port, 1310}, {control_panel_port, 2310}, {control_panel_redirect_port, 1356}, {rest_port, 3310}, {heart_beat, 1}, {nif_prefix, './'}, {ca_dir, './cacerts/'}],
              [{node_type, worker},
                  {dispatcher_port, 5058},
                  {ccm_nodes, [CCM]},
                  {dns_port, 1311}, {control_panel_port, 2311}, {control_panel_redirect_port, 1357}, {rest_port, 3311}, {heart_beat, 1}, {nif_prefix, './'}, {ca_dir, './cacerts/'}],
              [{node_type, worker},
                  {dispatcher_port, 5059},
                  {ccm_nodes, [CCM]},
                  {dns_port, 1312}, {control_panel_port, 2312}, {control_panel_redirect_port, 1358}, {rest_port, 3312}, {heart_beat, 1}, {nif_prefix, './'}, {ca_dir, './cacerts/'}]]),
  
  
      lists:append([{nodes, Nodes}], Config);
  
  init_per_testcase(init_and_cleanup_test, Config) ->
      ?INIT_CODE_PATH, ?CLEAN_TEST_DIRS,
      test_node_starter:start_deps_for_tester_node(),
  
      Nodes = test_node_starter:start_test_nodes(2),
      [CCM | _] = Nodes,
  
      test_node_starter:start_app_on_nodes(?APP_Name, ?VEIL_DEPS, Nodes,
          [[{node_type, ccm},
              {dispatcher_port, 5055},
              {ccm_nodes, [CCM]},
              {dns_port, 1308}, {control_panel_port, 2308}, {control_panel_redirect_port, 1354}, {rest_port, 3308}, {initialization_time, 1}, {heart_beat, 1}, {nif_prefix, './'}, {ca_dir, './cacerts/'}],
              [{node_type, worker},
                  {dispatcher_port, 5056},
                  {ccm_nodes, [CCM]},
                  {dns_port, 1309}, {control_panel_port, 2309}, {control_panel_redirect_port, 1355}, {rest_port, 3309}, {heart_beat, 1}, {nif_prefix, './'}, {ca_dir, './cacerts/'}]]),
  
  
      lists:append([{nodes, Nodes}], Config).
  
  end_per_testcase(_, Config) ->
      Nodes = ?config(nodes, Config),
      test_node_starter:stop_app_on_nodes(?APP_Name, ?VEIL_DEPS, Nodes),
      test_node_starter:stop_test_nodes(Nodes).
  
negative.code: %% sets up lager traces and if it cleans up after termination
  
  init_and_cleanup_test(Config) ->
      nodes_manager:check_start_assertions(Config),
  
      NodesUp = ?config(nodes, Config),
      [CCM, W] = NodesUp,
  