anchor.diff:          publish_item ->
               {TS, Id} = publish_pubsub_item(Client),
               amoc_metrics:update_counter(publication_query, 1),
  -            schedule_publishing(async),
               user_loop(Client, Requests#{Id=>{new, TS}});
           {'DOWN', _, process, Pid, Info} when Pid =:= Client#client.rcv_pid ->
               lager:error("TCP connection process ~p down: ~p", [Pid, Info]);
  
positive.code:     IqTimeout = get_parameter(iq_timeout),
      case escalus_pred:is_iq_result(PublishResult) of
          true ->
              schedule_publishing(sync_req),
              lager:debug("publish time ~p", [PublishTime]),
              amoc_metrics:update_counter(publication_result, 1),
              amoc_metrics:update_time(publication, PublishTime),
  
negative.code: -define(NODE, {pep, ?PEP_NODE_NS}).
  
  -define(GROUP_NAME, <<"pubsub_simple_coordinator">>).
  -define(NODE_CREATION_THROTTLING, <<"node_creation">>).
  -define(PUBLICATION_THROTTLING, <<"publication">>).
  
  -define(COORDINATOR_ID, 1).
  -define(COORDINATOR_TIMEOUT, 100000).
  