Lightweight Portable Message Queue Using 'SQLite'
Consume a message from a queue
Create a queue in a database
Positive or negative ackowledgement
Consume a message from a message queue
Create a queue
Try to consume a message from the queue
The name of the default database
Delete a queue
Ensure that the DB exists and has the right columns
Make sure that a queue exists
Check if a queue is empty
List failed messages in a queue
List all messages in a queue
List all queues in a database
Lightweight Portable Message Queue Using 'SQLite'
Make a message object
Get the number of messages in a queue.
Report that the work on a message has failed
Publish a message in a queue
Remove failed messages from the queue
Requeue failed messages
Consume a message if there is one available
Acknowledge that the work on a message has finished successfully
Temporary and permanent message queues for R. Built on top of 'SQLite' databases. 'SQLite' provides locking, and makes it possible to detect crashed consumers. Crashed jobs can be automatically marked as "failed", or put in the queue again, potentially a limited number of times.