Package index • liteq

All functions

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 messages 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