anchor.diff:  -define(GROUPNAME, <<"pubsub_test_group_name">>).
   -define(DELAY_BETWEEN_MESSAGES, 100).
   -define(WAIT_FOR_NODES, 10000).
  -
  --define(NODE_CREATE_TIME, [amoc, times, node_create_time]).
  --define(SUBSCRIBE_TIME, [amoc, times, subscribe_time]).
  --define(PUBLISH_TIME, [amoc, times, publish_time]).
  -
  --define(NODE_CREATE_FAILS_COUTER, [amoc, counters, node_create_failed]).
  --define(SUBSCRIBE_FAILS_COUTER, [amoc, counters, subscribe_failed]).
  --define(PUBLISH_FAILS_COUTER, [amoc, counters, publish_failed]).
  -
  --define(NODE_CREATE_SUCCESS_COUTER, [amoc, counters, node_create_success]).
  --define(SUBSCRIBE_SUCCESS_COUTER, [amoc, counters, subscribe_success]).
  --define(PUBLISH_SUCCESS_COUTER, [amoc, counters, publish_success]).
  --define(MESSAGE_TTD_CT, [amoc, times, message_ttd]).
  -
   
   -export([init/0]).
   -export([start/1]).
  
positive.code:         end),
      case escalus_pred:is_iq_result(SubscribeResult) of
          true ->
              exometer:update(?SUBSCRIBE_SUCCESS_COUTER, 1),
              exometer:update(?SUBSCRIBE_TIME, SubscribeTime);
          Error ->
              exometer:update(?SUBSCRIBE_FAILS_COUTER, 1),
              lager:error("Error subscribing node ~p filed: ~p", [Node, Error]),
              exit(connection_failed)
          end.
  
negative.code:         end),
      case escalus_pred:is_iq_result(PublishResult) of
          true ->
              amoc_metrics:update_counter(publish_success, 1),
              amoc_metrics:update_time(publish_time, PublishTime);
          Error ->
              amoc_metrics:update_counter(publish_fails, 1),
              lager:error("Error subscribing node ~p filed: ~p", [Node, Error]),
              exit(connection_failed)
          end.
  