Function getQueueOptions

server/redisConnection.js:89–128

()

};

const getQueueOptions = () => {
  // Check if cluster configuration is available
  const clusterConfig = getRedisClusterOptions();
  const removeOnCompleteAge = parsePositiveInt(
    process.env.CB_QUEUE_KEEP_COMPLETE_AGE_SECONDS,
    86400
  );
  const removeOnCompleteCount = parsePositiveInt(
    process.env.CB_QUEUE_KEEP_COMPLETE_COUNT,
    1000
  );
  const removeOnFailAge = parsePositiveInt(
    process.env.CB_QUEUE_KEEP_FAIL_AGE_SECONDS,
    604800
  );
  const removeOnFailCount = parsePositiveInt(process.env.CB_QUEUE_KEEP_FAIL_COUNT, 5000);

  return {
    connection: clusterConfig || getRedisOptions(),
    defaultJobOptions: {
      attempts: 3,
      backoff: {
        type: "fixed",
        delay: 5000
      },
      removeOnComplete: {
        age: removeOnCompleteAge,
        count: removeOnCompleteCount,
      },
      removeOnFail: {
        age: removeOnFailAge,
        count: removeOnFailCount,
      },
    },
    settings: {
      stalledInterval: 30000,
      maxStalledCount: 3,
    }
  };
};

module.exports = {
  getRedisOptions,