Send message to workers — rrq_message

Send a message to workers. Sending a message returns a message id, which can be used to poll for a response with the other rrq_message_* functions. See vignette("messages") for details for the messaging interface.

Usage

rrq_message_send(command, args = NULL, worker_ids = NULL, controller = NULL)

Arguments

command: A command, such as PING, PAUSE; see the Messages section of the Details for al messages.
args: Arguments to the command, if supported
worker_ids: Optional vector of worker ids to send the message to. If NULL then the message will be sent to all active workers.
controller: The controller to use. If not given (or NULL) we'll use the controller registered with rrq_default_controller_set().

Value

Invisibly, a single identifier

Examples

if (FALSE) { # rrq:::enable_examples(require_queue = "rrq:example")
obj <- rrq_controller("rrq:example")

id <- rrq_message_send("PING", controller = obj)
rrq_message_get_response(id, timeout = 5, controller = obj)
}