pgq-coop
Организация кооперативных очередей сообщений.
Связанные компоненты: pgq.
Схема размещения:
pgq_coop.Опциональное расширение, реализованное на языке
plpgsql и предназначенное для организации кооперативных очередей. Для одного генератора сообщений могут присутствовать несколько получателей.Функции:
| Функция | Входные параметры | Описание |
|---|---|---|
finish_batch | i_batch_id, int8 | Завершает сеанс по его идентификатору batch_id. Решение принимается солидарно для каждого отдельного получателя |
next_batch | - i_queue_name, text; - i_consumer_name, text; - i_subconsumer_name, text \[i_dead_interval interval\] | Предоставляет информацию о сеансе для получателя. Аналог функции pgq.next_batch |
next_batch_custom | - i_queue_name, text; - i_consumer_name, text; - i_subconsumer_name, text; - i_min_lag, interval; - i_min_count, integer; - i_min_interval, interval, \[i_dead_interval, interval\] | Предоставляет расширенную информацию о сеансе. Аналог функции pgq.next_batch_custom |
register_subconsumer | - i_queue_name, text; - i_consumer_name, text; - i_subconsumer_name, text; - i_subconsumer_name, text | Регистрирует получателя сообщения в очереди |
unregister_subconsumer | - i_queue_name, text; - i_consumer_name, text; - i_subconsumer_name, text; - i_batch_handling, integer | Отменяет регистрацию получателя |
Требуется предварительная установка расширения pgq.
Дополнительную информацию по поставляемому модулю pgq-coop можно получить по ссылке.