anchor.diff:  subscriber_loop(Client) ->
       try escalus:wait_for_stanza(Client, ?WAIT_FOR_STANZA_TIMEOUT) of
           Stanza ->
  -            lager:debug("Received ~p ~n", [Stanza])
  +            escalus:assert(is_message, Stanza),
  +            Item = exml_query:path(Stanza, [{element, <<"event">>}, {element, <<"items">>}, {element, <<"item">>}]),
  +            TimeStampBin = exml_query:attr(Item, <<"id">>),
  +            TimeStamp = binary_to_integer(TimeStampBin),
  +            TTD =  os:system_time(microsecond) - TimeStamp,
  +            exometer:update(?MESSAGE_TTD_CT, TTD),
  +            lager:info("~n~n~p~n~n", [Stanza])
       catch
           Error:Reason ->
               lager:error("No items received! ~p~n ~p~n", [Error, Reason])
  
positive.code: -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]).
  
  -export([init/0]).
  -export([start/1]).
  
negative.code: 
  publisher_loop(Client, Nodes) ->
      receive
          {scheduled, publish_item} ->
              publish(Client, Nodes),
              schedule(publish_item, ?DELAY_BETWEEN_MESSAGES)
      end,
      publisher_loop(Client, Nodes).
  
  publish(Client, Nodes) ->
      lager:debug("Published ~p ~n", [Nodes]),
      [ publish_pubsub_item(Client, Node) || Node <- Nodes ].
  
  %% --- Subscriber -------------------------------------------------------------------------------------------
  subscriber_start(Client) ->
  