consume | R Documentation |
Blocks and waits for a message if there isn't one to work on currently.
consume(queue, poll_interval = 500)
queue |
The queue object. |
poll_interval |
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()
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.