RedisQueue: RedisQueue object

In lecardozo/rworker: Celery Worker For R Tasks

Description

This object establishes an interface for Redis as a message broker

Arguments

name	The name of the queue.
host	Message broker instance address.
port	Message broker port.
username	Ignored (included for consistency with other non-Redis queues)
password	Redis password
db	Database number

Usage

queue <- RedisQueue$new(host='localhost',
                        port=6379, name='celery',
                        password=NULL, db=0)
msg <- queue$pull()
queue$push(msg)

lecardozo/rworker documentation built on May 12, 2021, 5:37 p.m.