db_consume: Consume a message from a message queue

View source: R/db.R

db_consumeR Documentation

Consume a message from a message queue

Description

This is the blocking version of try_consume(). Currently it just polls twice a second, and sleeps between the polls. Each poll will also trigger a crash cleanup, if there are workers running.

Usage

db_consume(db, queue, poll_interval = 500)

Arguments

queue

The queue object.


liteq documentation built on Nov. 5, 2026, 5:07 p.m.