anchor.diff:      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);
  
positive.code:             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])
      catch
          Error:Reason ->
              lager:error("No items received! ~p~n ~p~n", [Error, Reason])
  
negative.code: creator_start(Client) ->
      pg2:join(?GROUPNAME, self()),
      Nodes = [create_pubsub_node(Client)],
      schedule(start_publishing_items, ?DELAY_BETWEEN_MESSAGES),
      creator_loop(Client, Nodes).
  
  