Существует таблица очередей в Oracle (queue_table), в которую сыпятся записи в больших количествах.
Первое, что приходит на ум, это повесить на таблицу подписчика, который будет вычитывать (dequeue) каждую запись. Но это слишком затратно. Можно запустить джоб, который будет раз в минуту вычитывать скопом массив (dequeue_array) записей. Но джоб тоже не лучшее решение.