anchor.diff:      Nodes = get_nodes(3, Client),
       case Id rem ?PUBLISHER_SUBSCRIBER_DENOMINATOR of
           X when X =< ?PUBLISHERS_NUMERATOR ->
  -            lager:info("Client: Starting publisher Id = ~p\n", [Id]),
  +            lager:debug("Client: Starting publisher Id = ~p\n", [Id]),
               publish_items_forever(Client, Id, Nodes, 1);
           _ ->
  -            lager:info("Client: Starting subscriber Id = ~p\n", [Id]),
  +            lager:debug("Client: Starting subscriber Id = ~p\n", [Id]),
               work_as_subscriber(Id, Client, Nodes)
       end,
       ok.
   
   provide_nodes_names(SelfClient, Nodes) ->
       receive
  -        {what_nodes, PID, Client} ->
  -            AffChange = [{Client, <<"publisher">>}],
  -            [ set_affiliations(SelfClient, Node, AffChange) || Node <- Nodes],
  +        {what_nodes, PID} ->
               PID ! {nodes, Nodes}
       end,
       provide_nodes_names(SelfClient, Nodes).
  
positive.code: create_pubsub_node(Client) ->
      Node = pubsub_node(),
      ReqId = id(Client, Node, <<"create">>),
      Request = escalus_pubsub_stanza:create_node(Client, ReqId,
  						Node, []),
      escalus:send(Client, Request),
      Response = escalus:wait_for_stanza(Client,
  				       ?WAIT_FOR_STANZA_TIMEOUT),
  
negative.code:     timer:sleep(?DELAY_BETWEEN_MESSAGES),
      ItemIdBin = integer_to_binary(ItemId),
      Resp = [ publish_pubsub_item(Client, <<"item_", ItemIdBin/binary>>, Node) || Node <- Nodes ],
      lager:debug("Client: Response is ~p\n", [Resp]),
      publish_items_forever(Client, Id, Nodes, ItemId + 1).
  
  work_as_subscriber(Id, Client, Nodes) ->
      [subscribe(Client, Node) || Node <- Nodes],
      lager:debug("Client: Subscriber ~p subscribed to ~p nodes.", [Id, length(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).
  
  
  