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