Worker

Queue Listener

Functionalities

init()

    initialize worker

start()

    start worker (start listen to queue and pull messages)

Events

• error: Fired on general errors.
• message_error: Fired when an error occurs processing the message.
• message_received: Fired when a message is received.
• message_processed: Fired when a message is successfully processed and removed from the queue.
• stopped: Fired when the consumer finally stops its work.
• idle: Fired when the queue is empty (All messages have been consumed).

    Example

  const workerFactory = require('queue-router').workerFactory;
  const worker = workerFactory.create(workerFactory.Types.SQS, router, config);
  worker.init().then(() => worker.start());

  worker.on('error', (error) => {});
  worker.on('message_error', (message_error) => {});
  worker.on('message_received', () => {});
  worker.on('message_processed', () => {});
  worker.on('stopped', () => {});
  worker.on('idle', () => {});