Во-первых, вы потратите наименьшее количество усилий, если просто займётесь работой cron.
Однако, если вы начинаете с scracth: вы пытаетесь периодически реплицировать строки из вашей базы данных. Я думаю, что вы смотрите на очередь репликации.
Проект PGQ (используется для репликации Londiste, оба из SkypeTools Skype) имеет очередь, которую вы можете использовать независимо. Когда настраивает его , вы устанавливаете максимальное количество событий и задержку цикла перед генерацией пакетных событий. Таким образом, вы можете получать партии с интервалом не более 15 секунд. Теперь вам нужно создать события, которые будут упакованы, используя триггер, который вызывает pgq.insert_event ; и потреблять очереди. Потребитель может вызвать ваш хранимый процесс PL / Java; вам придется переписать процедуру, чтобы отправить все в пакете, а не сканировать базовую таблицу на наличие новых событий.