CREATE OR REPLACE FUNCTION public.notify_object_inserted()
  RETURNS trigger AS
$BODY$
DECLARE
BEGIN
  PERFORM pg_notify(
    'object_inserted'::text,
    json_build_object(NEW.object_uid, NEW.user_uid)::text);
  RETURN NEW;
END;
$BODY$
  LANGUAGE plpgsql VOLATILE
  COST 100;
ALTER FUNCTION public.notify_object_inserted()
  OWNER TO test_user;


CREATE TRIGGER notify_object_inserted
  AFTER INSERT
  ON public.objects
  FOR EACH ROW
  EXECUTE PROCEDURE public.notify_object_inserted();

var
  FDEventAlerter1: TFDEventAlerter;

  FDEventAlerter1 := TFDEventAlerter.Create(Self);

  FDEventAlerter1.Name := 'FDEventAlerter1';
  FDEventAlerter1.Connection := FDConnection5;
  FDEventAlerter1.Names.Clear;
  FDEventAlerter1.Names.Add('object_inserted');
  FDEventAlerter1.OnAlert := FDEventAlerter1Alert;

  FDEventAlerter1.Active := True;
  FDEventAlerter1.Register;

-- Notify when record was inserted into 'prices' table
CREATE OR REPLACE FUNCTION notify_pricesinserted()
  RETURNS trigger AS $$
DECLARE
BEGIN
  PERFORM pg_notify(
    CAST('pricesinserted' AS text),
    row_to_json(NEW)::text);
  RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER notify_pricesinserted
  AFTER INSERT ON prices
  FOR EACH ROW
  EXECUTE PROCEDURE notify_pricesinserted();

function TFDPhysEventMessage.Perform(AThread: TFDThread): Boolean;
begin
  FMsgThread := AThread as TFDPhysEventThread;
  if FMsgThread.Active then begin
    if FMsgThread.FAlerter.GetOptions.Synchronize then
      TFDThread.Queue(nil, BasePerform)
    else
      BasePerform;
  end;
  Result := True;
end;