anchor.diff:          {message, {what_nodes, PID}} ->
               PID ! {nodes, Nodes};
           {scheduled, start_publishing_items} ->
  -            schedule({publish_item, 1}, ?DELAY_BETWEEN_MESSAGES);
  -        {scheduled, {publish_item, ItemId}} ->
  -            schedule({publish_item, ItemId + 1}, ?DELAY_BETWEEN_MESSAGES),
  -            publish(Client, Nodes, ItemId)
  +            schedule(publish_item, ?DELAY_BETWEEN_MESSAGES);
  +        {scheduled, publish_item} ->
  +            schedule(publish_item, ?DELAY_BETWEEN_MESSAGES),
  +            publish(Client, Nodes)
       end,
       creator_loop(Client, Nodes).
   
  
positive.code: subscriber_loop(Client) ->
      try escalus:wait_for_stanza(Client, ?WAIT_FOR_STANZA_TIMEOUT) of
          Stanza ->
              lager:debug("Received ~p ~n", [Stanza])
      catch
          Error:Reason ->
              lager:error("No items received! ~p~n ~p~n", [Error, Reason])
  
negative.code:         {?PUBLISH_SUCCESS_COUTER, spiral},
          {?NODE_CREATE_TIME, histogram},
          {?SUBSCRIBE_TIME, histogram},
          {?PUBLISH_TIME, histogram},
          {?MESSAGE_TTD_CT, histogram}
      ],
      [create_stat(Path, GraphType) ||  {Path, GraphType} <- Stats].
  
  