db_consume: Consume a message from a message queue
In r-lib/liteq: Lightweight Portable Message Queue Using 'SQLite'
db_consume 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.
r-lib/liteq documentation built on Nov. 10, 2023, 1:43 a.m.
R Package Documentation
Browse R Packages
We want your feedback!
Note that we can't provide technical support on individual packages. You should contact the package authors for that.
| db_consume | 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. |
R Package Documentation
Browse R Packages
We want your feedback!
Note that we can't provide technical support on individual packages. You should contact the package authors for that.
Embedding an R snippet on your website
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.