rrq_message_get_response: Get message response

In mrc-ide/rrq: Simple Redis Queue

Get message response

Description

Get response to messages, waiting until the message has been responded to.

Usage

rrq_message_get_response(
  message_id,
  worker_ids = NULL,
  named = TRUE,
  delete = FALSE,
  timeout = 0,
  time_poll = 0.5,
  progress = NULL,
  controller = NULL
)

Arguments

message_id	The message id
worker_ids	Optional vector of worker ids. If NULL then all active workers are used (note that this may differ to the set of workers that the message was sent to!)
named	Logical, indicating if the return value should be named by worker id.
delete	Logical, indicating if messages should be deleted after retrieval
timeout	Integer, representing seconds to wait until the response has been received. An error will be thrown if a response has not been received in this time.
time_poll	If timeout is greater than zero, this is the polling interval used between redis calls. Increasing this reduces network load but increases the time that may be waited for.
progress	Optional logical indicating if a progress bar should be displayed. If NULL we fall back on the value of the global option rrq.progress, and if that is unset display a progress bar if in an interactive session.
controller	The controller to use. If not given (or NULL) we'll use the controller registered with rrq_default_controller_set().

Examples

obj <- rrq_controller("rrq:example")
id <- rrq_message_send("PING", controller = obj)
rrq_message_get_response(id, timeout = 5, controller = obj)

mrc-ide/rrq documentation built on Nov. 28, 2024, 1:12 p.m.