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 |