anchor.diff:  % Private API
   %
   
  +ping() ->
  +    %% Send a PING command every 15s
  +    erlang:send_after(15000, self(), ping).
  +
   send_events(_, _, []) ->
       ok;
   send_events(YawsPid, Domain, [#uce_event{datetime=Datetime} = Event|Events]) ->
  
positive.code:             send_events(YawsPid, Domain, [Event])
      end,
      {noreply, State};
  handle_info(Event, State) ->
      ?ERROR_MSG("unexpected ~p", [Event]),
      {noreply, State}.
  
negative.code:     send_events(YawsPid, Domain, PreviousEvents),
      ?PUBSUB_MODULE:subscribe(self(), Domain, Location, From, Types, Parent),
      uce_presence:add_stream(Domain, Sid),
      ping(),
      {ok, {YawsPid,
            Domain,
            Search,
  