Consume a message from a queue

Blocks and waits for a message if there isn't one to work on currently.

Usage

consume(queue, poll_interval = 500)

Arguments

queue

The queue object.

poll_interval

Poll interval in milliseconds. How often to poll the queue for new jobs, if none are immediately available.

Value

A message.

See also

liteq for examples

Other liteq messages: ack(), is_empty(), list_failed_messages(), list_messages(), message_count(), publish(), remove_failed_messages(), requeue_failed_messages(), try_consume()