getMessage: A function that takes a queue and a serialization type and...

In PieceMaker/RMinions: A Package for Easy R Processing Scalability Via Message Queues

Description

getMessage takes a Redis connection, a string queue, and a boolean specifying whether the serialization was JSON or not. It then gets the message from the queue, parses it, and returns the parsed message.

Usage

getMessage(conn, queue, useJSON = F, blocking = F)

Arguments

conn	An open redux hiredis connection.
queue	A string giving the name of the queue to get the message from.
useJSON	Flag specifying whether messages are in JSON format. Defaults to false.
blocking	Flag specifying whether a blocking pop or regular pop will be performed when getting a message from the queue.

PieceMaker/RMinions documentation built on Oct. 21, 2019, 8:01 p.m.