Class AmqplibAxiosWorker

A customized implementation of the RateLimitedQueueClient that uses axios to make requests and returns the responses via amqplib. Works with the amqplib-oop-axios Adapter.

Example

import { AmqplibAxiosWorker } from '@jakguru/amqplib-oop-axios'

const worker = new AmqplibAxiosWorker(
    'example-queue',
    {}, // amqplib connection options
    {
        interval: 1000, // 1 second in ms
        perInterval: 10, // 10 requests per interval
        autostart: true,
    },
    {
        baseURL: 'https://some-domain.com/api',
    }
)
// Optional: Update the axios defaults
worker.defaults.headers.common['Authorization'] = AUTH_TOKEN;

// Optional: Add interceptors
worker.interceptors.request.use(function (config) {
    // Do something before request is sent
    return config;
  }, function (error) {
    // Do something with request error
    return Promise.reject(error);
  });
Copy