pgqworks

pgq.sql

-- sample pgq working example with internal ticker call

   select pgq.create_queue('LogEvent');
   select pgq.insert_event('LogEvent', 'data', 'DataFor123');
   select pgq.register_consumer('LogEvent', 'TestConsumer');
   
   select pgq.ticker();
   

   select pgq.next_batch('LogEvent', 'TestConsumer'); 
   select pgq.get_batch_events(1);
   select pgq.finish_batch(1)