Blocks and waits for a message if there isn't one to work on currently.
consume(queue, poll_interval = 500)The queue object.
Poll interval in milliseconds. How often to poll the queue for new jobs, if none are immediately available.
A message.
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