anchor.diff:          publish_item ->
               {TS, Id} = publish_pubsub_item(Client, Node),
               amoc_metrics:update_counter(publication_query, 1),
  -            schedule_publishing(async),
               user_loop(Client, Node, 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:     Entry = exml_query:path(Stanza, [{element, <<"event">>}, {element, <<"items">>},
                                       {element, <<"item">>}, {element, <<"entry">>}]),
      case {exml_query:attr(Entry, <<"jid">>), erlang:get(jid)} of
          {JID, JID} -> schedule_publishing(sync_rcv);
          _ -> ok
      end,
      TimeStampBin = exml_query:attr(Entry, <<"timestamp">>),
  
negative.code:             get_coordinator_pid()
      end.
  
  %%------------------------------------------------------------------------------------------------
  %% User
  %%------------------------------------------------------------------------------------------------
  