anchor.diff:      Request = escalus_pubsub_stanza:publish(Client, ItemId, item_content(), Id, Node),
       escalus:send(Client, Request),
       Response = escalus:wait_for_stanza(Client, ?WAIT_FOR_STANZA_TIMEOUT),
  -    lager:info("Client: Publisher:  Response is: ~n~p~n", [Response]),
  +    lager:debug("Client: Publisher:  Response is: ~n~p~n", [Response]),
       true = escalus_pred:is_iq_result(Response).
   
   item_content() ->
       #xmlel{name = <<"entry">>,
              attrs = [{<<"xmlns">>, <<"http://www.w3.org/2005/Atom">>}]}.
  -
  -set_affiliations(Client, Node, AffChange) ->
  -    Id = id(Client, Node, <<"set_affs">>),
  -    Request = escalus_pubsub_stanza:set_affiliations(Client, Id, Node, AffChange),
  -    escalus:send(Client, Request),
  -    Response = escalus:wait_for_stanza(Client, ?WAIT_FOR_STANZA_TIMEOUT),
  -    lager:info("Client: Publisher: Change Afilations Response is: ~n~p~n", [Response]),
  -    true = escalus_pred:is_iq_result(Response).
  
positive.code:     timer:sleep(?DELAY_BETWEEN_MESSAGES),
      ItemIdBin = integer_to_binary(ItemId),
      Resp = [ publish_pubsub_item(Client, <<"item_", ItemIdBin/binary>>, Node) || Node <- Nodes ],
      lager:info("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:info("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:info("Client: Subscriber ~p got stanza ~p.", [Id, Stanza]),
      receive_messages_forever(Id, Client).
  
  
  
negative.code:     loger:error("Client: NO NODES PROVIDED"),
      [];
  get_nodes(Retries, Client) ->
      case erlang:get(nodes_names) of
          {nodes_names, Nodes} ->
              Nodes;
          _ ->
              Members = pg2:get_members(?GROUPNAME),
              [ M ! {what_nodes, self()} || M <- Members ],
              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.
  