db_consume {liteq} | R 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. |
[Package liteq version 1.1.0 Index]