anchor.diff:          end),
       case escalus_pred:is_iq_result(SubscribeResult) of
           true ->
  -            exometer:update(?SUBSCRIBE_SUCCESS_COUTER, 1),
  -            exometer:update(?SUBSCRIBE_TIME, SubscribeTime);
  +            amoc_metrics:update_counter(subscribe_success, 1),
  +            amoc_metrics:update_time(subscribe_time, SubscribeTime);
           Error ->
  -            exometer:update(?SUBSCRIBE_FAILS_COUTER, 1),
  +            amoc_metrics:update_counter(subscribe_fails, 1),
               lager:error("Error subscribing node ~p filed: ~p", [Node, Error]),
               exit(connection_failed)
           end.
  
positive.code:         end),
      case escalus_pred:is_iq_result(PublishResult) of
          true ->
              exometer:update(?PUBLISH_SUCCESS_COUTER, 1),
              exometer:update(?PUBLISH_TIME, PublishTime);
          Error ->
              exometer:update(?PUBLISH_FAILS_COUTER, 1),
              lager:error("Error subscribing node ~p filed: ~p", [Node, Error]),
              exit(connection_failed)
          end.
  
negative.code: -define(GROUPNAME, <<"pubsub_test_group_name">>).
  -define(DELAY_BETWEEN_MESSAGES, 100).
  -define(WAIT_FOR_NODES, 10000).
  
  -export([init/0]).
  -export([start/1]).
  