consume {liteq}

Consume a message from a queue

Description

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