WorkerFactory

Workers Generator

Functionalities

create(worker_type, router, config)

    Create new worker

    Params

1. worker_type: SQS, RabbitMQ - TBD

const workerFactory = require('queue-router').workerFactory;
// workerFactory.Types.SQS
// workerFactory.Types.RabbitMQ

2. router: route table

  const Router = require('queue-router').Router;
  const router = new Router();
  // ...

3. config: queue configuration    
   

• SQS Config

{
   "queue": { // object, required
      "aws": { // object, required
         "credentials": { // object, optional
            "region": "", // string, optional, (default from env AWS_REGION)
            "accessKeyId": "", // string, optional, (default from env AWS_ACCESS_KEY_ID)
            "secretAccessKey": "", // string, optional, (default from env secretAccessKey)
         },
         "batchSize": "", //int, optional, (size of batch, default 10)
         "queueUrl": "", //string, required, (url to sqs)
}