anchor.diff:      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]),
  +    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:info("Client: Subscriber ~p subscribed to ~p nodes.", [Id, length(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:info("Client: Subscriber ~p got stanza ~p.", [Id, Stanza]),
  +    lager:debug("Client: Subscriber ~p got stanza ~p.", [Id, Stanza]),
       receive_messages_forever(Id, Client).
   
   
  
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:     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.
  