consume: Consume a message from a queue

In r-lib/liteq: Lightweight Portable Message Queue Using 'SQLite'

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()

r-lib/liteq documentation built on Nov. 11, 2024, 10:21 a.m.