consume function

Consume a message from a queue

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

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.

Returns

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