anchor.diff:      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(), Client} || M <- Members ],
  +            [ M ! {what_nodes, self()} || M <- Members ],
               receive
                   {nodes, Nodes} ->
                       erlang:put(nodes_names, {nodes_names, Nodes}),
                       Nodes
               after
                   ?WAIT_FOR_NODES ->
  -                    logger:info("Client: PID \n~p\n TIMEOUT", []),
  +                    logger:debug("Client: PID \n~p\n TIMEOUT", []),
                       get_nodes(Retries - 1, Client)
               end
       end.
  
positive.code:     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]),
      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).
  
negative.code: create_pubsub_node(Client) ->
      Node = pubsub_node(),
      ReqId = id(Client, Node, <<"create">>),
      NodeConfig = [{<<"pubsub#subscribe">>, <<"1">>},
                    {<<"pubsub#access_model">>, <<"open">>},
                    {<<"pubsub#publish_model">>, <<"open">>}],
      Request = escalus_pubsub_stanza:create_node(Client, ReqId,
  						Node, NodeConfig),
      escalus:send(Client, Request),
      Response = escalus:wait_for_stanza(Client,
  				       ?WAIT_FOR_STANZA_TIMEOUT),
  