anchor.diff:              TimeStampBin = exml_query:attr(Item, <<"id">>),
               TimeStamp = binary_to_integer(TimeStampBin),
               TTD =  os:system_time(microsecond) - TimeStamp,
  -            amoc_metrics:update_time(message_ttd, TTD),
  -            lager:info("~n~n~p~n~n", [Stanza])
  +            amoc_metrics:update_time(message_ttd, TTD)
       catch
           Error:Reason ->
               lager:error("No items received! ~p~n ~p~n", [Error, Reason])
  
positive.code:     pg2:create(?GROUPNAME),
      CreatorsNumber = amoc_config:get('NUMBER_OF_NODE_CREATORS', 3),
      Client = connect_amoc_user(Id),
      lager:info("~p~p", [Id, Client]),
      case assign_role(Id, CreatorsNumber) of
          creator ->
              creator_start(Client);
  
negative.code: %% --- Publisher --------------------------------------------------------------------------------------------
  publisher_start(Client) ->
      Nodes = get_nodes(3, Client),
      schedule({publish_item, 1}, ?DELAY_BETWEEN_MESSAGES),
      publisher_loop(Client, Nodes).
  
  