liteq-package | Lightweight Portable Message Queue Using 'SQLite' |
ack | Acknowledge that the work on a message has finished successfully |
consume | Consume a message from a queue |
create_queue | Create a queue in a database |
default_db | The name of the default database |
delete_queue | Delete a queue |
ensure_queue | Make sure that a queue exists |
is_empty | Check if a queue is empty |
list_failed_messages | List failed messages in a queue |
list_messages | List all messages in a queue |
list_queues | List all queues in a database |
liteq | Lightweight Portable Message Queue Using 'SQLite' |
message_count | Get the number of messages in a queue. |
nack | Report that the work on a message has failed |
publish | Publish a message in a queue |
remove_failed_messages | Remove failed messages from the queue |
requeue_failed_messages | Requeue failed messages |
try_consume | Consume a message if there is one available |