anchor.diff:          end),
       case escalus_pred:is_iq_result(SubscribeResult) of
           true ->
  -            amoc_metrics:update_counter(subscribe_success, 1),
  -            amoc_metrics:update_time(subscribe_time, SubscribeTime);
  +            amoc_metrics:update_counter(subscription_success, 1),
  +            amoc_metrics:update_time(subscription, SubscribeTime);
           Error ->
  -            amoc_metrics:update_counter(subscribe_fails, 1),
  +            amoc_metrics:update_counter(subscription_failure, 1),
               lager:error("Error subscribing node ~p filed: ~p", [Node, Error]),
               exit(connection_failed)
           end.
  
positive.code: 
      case escalus_pred:is_iq_result(CreateNodeResult) of
          true ->
              amoc_metrics:update_counter(node_create_success, 1),
              amoc_metrics:update_time(node_create_time, CreateNodeTime);
          Error ->
              amoc_metrics:update_counter(node_create_fails, 1),
              lager:error("Error creating node: ~p", [Error]),
              exit(connection_failed)
      end,
  
negative.code:         end),
      case escalus_pred:is_iq_result(PublishResult) of
          true ->
              amoc_metrics:update_counter(publication_success, 1),
              amoc_metrics:update_time(publication, PublishTime);
          Error ->
              amoc_metrics:update_counter(publication_failure, 1),
              lager:error("Error subscribing node ~p filed: ~p", [Node, Error]),
              exit(connection_failed)
          end.
  