Queue PubSub

Description

Thanks to the change feed technology build into RethinkDB, rethinkdb-job-queue can be a distributed system. Depending on how you configure the Queue object you can have Publisher nodes or Subscriber nodes running on the same host or spread across multiple hosts.

The configuration for a Publisher or Subscriber Queue object is very similar. The only difference is the subscriber has the Queue.process method call passing your handler function.

This document describes the configuration for both a Publisher and Subscriber Queue object.

Publisher Queue Object

To create a Publisher you need to create the Queue object using the Queue Constructor. This is the same if you are creating a Subscriber.

This example creates a Queue object named pub used for adding jobs to the queue. It will not process jobs.