delayingRequestExecution_constructQueue_taskQueue.js

// undo-queue.js

"use strict";

const crypto = require("crypto");
const Queue = require("bull");

const undoQueueWorkers = new Map();
const { redis: redisConfig } = require("../config");

const queue = new Queue("undoQueue", {
  redis: {
    host: redisConfig.host,
    port: redisConfig.port,
    password: redisConfig.password,
    reconnectOnError: () => true,
    enableOfflineQueue: true,
    enableReadyCheck: true,
    keyPrefix: "undoable",
    connectTimeout: 20000,
    db: redisConfig.undoQueueDB
  },
  defaultJobOptions: {
    delay: 10000,
    attempts: 2,
    backoff: {
      delay: 2000,
      type: "exponential"
    },
    removeOnComplete: true,
    removeOnFail: true
  }
});

// file continues...