anchor.diff:              Nodes;
           _ ->
               Member = try_get_member([]),
  -            Member ! {what_nodes, self()},
  +            Member ! {message, {what_nodes, self()}},
               receive
                   {nodes, Nodes} ->
                       erlang:put(nodes_names, {nodes_names, Nodes}),
                       Nodes
               after
                   ?WAIT_FOR_NODES ->
  -                    logger:debug("Client: PID \n~p\n TIMEOUT", []),
                       get_nodes(Retries - 1, Client)
               end
       end.
   
  -publish_items_forever(Client, Id, Nodes, ItemId) ->
  -    timer:sleep(?DELAY_BETWEEN_MESSAGES),
  -    publish(ItemId, Client, Nodes),
  -    publish_items_forever(Client, Id, Nodes, ItemId + 1).
  -
  -publish(ItemId, Client, Nodes) -> 
  -    ItemIdBin = integer_to_binary(ItemId),
  -    Resp = [ publish_pubsub_item(Client, <<"item_", ItemIdBin/binary>>, Node) || Node <- Nodes ],
  -    lager:debug("Client: Response is ~p\n", [Resp]).
  -
  -work_as_subscriber(Id, Client, Nodes) ->
  -    [subscribe(Client, Node) || Node <- Nodes],
  -    lager:info("Subscriber, node: ~p~n", [Nodes]),
  -    receive_messages_forever(Id, Client).
  -
  -receive_messages_forever(Id, Client) ->
  -    Stanza = escalus:wait_for_stanza(Client, ?WAIT_FOR_STANZA_TIMEOUT),
  -    lager:debug("Client: Subscriber ~p got stanza ~p.", [Id, Stanza]),
  -    receive_messages_forever(Id, Client).
  -
  -
  -%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  -%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% Helpers %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  -%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  -
  -
  +%% --- User helpers -----------------------------------------------------------------------------------------
   connect_amoc_user(Id) ->
       connect_amoc_user(Id, <<"res1">>).
   
  
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:         {?SUBSCRIBE_TIME, histogram},
          {?PUBLISH_TIME, histogram}
      ],
      [create_stat(Path, GraphType) ||  {Path, GraphType} <- Stats].
  
  create_stat(Path, spiral) ->
      exometer:new(Path, spiral),
  