anchor.diff:  item_content() ->
       #xmlel{name = <<"entry">>,
              attrs = [{<<"xmlns">>, <<"http://www.w3.org/2005/Atom">>}]}.
  +
  +%% --- General Helpers ------------------------------------------------------------------------------------------------
  +
  +try_get_member([]) ->
  +    Members = pg2:get_members(?GROUPNAME),
  +    try_get_member(Members);
  +try_get_member(Members) ->
  +    L = length(Members),
  +    N = erlang:phash2(self(), L) + 1,
  +    lists:nth(N, Members).
  
positive.code: -define(PUBSUB_ADDR, <<"pubsub.localhost">>).
  -define(WAIT_FOR_STANZA_TIMEOUT, 10000).
  -define(GROUPNAME, <<"pubsub_test_group_name">>).
  -define(NUMBER_OF_PUBSUB_NODES, 5).
  -define(DELAY_BETWEEN_MESSAGES, 100).
  -define(WAIT_FOR_NODES, 10000).
  -define(PUBLISHER_SUBSCRIBER_DENOMINATOR, 6).
  -define(PUBLISHERS_NUMERATOR, 2).
  
  -define(NODE_CREATE_TIME, [amoc, timers, node_create_time]).
  -define(SUBSCRIBE_TIME, [amoc, timers, subscribe_time]).
  
negative.code: -export([start/1]).
  
  -required_variable({'NUMBER_OF_NODE_CREATORS', <<"Specifies how many users will create node"/utf8>>}).
  -required_variable({'PUBLISHERS_RATIO', <<"Specifies the number of publishers per 10 users"/utf8>>}).
  
  -spec init() -> ok.
  init() ->
      init_metrics(),
      ok.
  
  -spec start(amoc_scenario:user_id()) -> any().
  start(Id) ->
      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);
          publisher ->
              publisher_start(Client);
          subscriber ->
              subscriber_start(Client)
      end.
  
  %% --- Metrics ---------------------------------------------------------------------------------------------
  
  init_metrics() ->
      Stats =
      [
          {?NODE_CREATE_FAILS_COUTER, spiral},
  