constructor(redisQueuePrefix, options) {

    this.redisQueuePrefix = redisQueuePrefix;

    this.concurrency = options.concurrency || 2;

    this.continueWaitTimeout = options.continueWaitTimeout || 5;

    this.executionTimeout = options.executionTimeout || 600;

    this.orphanedTimeout = options.orphanedTimeout || 120;

    this.heartBeatInterval = options.heartBeatInterval || 30;

    this.sendProcessMessageFn = options.sendProcessMessageFn || ((queryKey) => { this.processQuery(queryKey); });

    this.sendCancelMessageFn = options.sendCancelMessageFn || ((query) => { this.processCancel(query); });

    this.queryHandlers = options.queryHandlers;

    this.cancelHandlers = options.cancelHandlers;

    this.logger = options.logger || ((message, event) => console.log(`${message} ${JSON.stringify(event)}`));

    const queueDriverOptions = {

      redisQueuePrefix: this.redisQueuePrefix,

      concurrency: this.concurrency,

      continueWaitTimeout: this.continueWaitTimeout,

      orphanedTimeout: this.orphanedTimeout,

      heartBeatTimeout: this.heartBeatInterval * 4,

      redisPool: options.redisPool

    };

    this.queueDriver = options.cacheAndQueueDriver === 'redis' ?

      new RedisQueueDriver(queueDriverOptions) :

      new LocalQueueDriver(queueDriverOptions);

  }

edisPrefix  Prefix to be set an all Redis keys  STANDALONE

rollupOnlyMode  When enabled, an error will be thrown if a query can't be served from a pre-aggregation (rollup)  false

queryCacheOptions Query cache options for DB queries  {}

queryCacheOptions.refreshKeyRenewalThreshold  Time in seconds to cache the result of refreshKey check defined by DB dialect

queryCacheOptions.backgroundRenew Controls whether to wait in foreground for refreshed query data if refreshKey value has been changed. Refresh key queries or pre-aggregations are never awaited in foreground and always processed in background unless cache is empty. If true it immediately returns values from cache if available without refreshKey check to renew in foreground. Default value before 0.15.0 was true false

queryCacheOptions.queueOptions  Query queue options for DB queries  {}

preAggregationsOptions  Query cache options for pre-aggregations  {}

preAggregationsOptions.queueOptions Query queue options for pre-aggregations  {}

preAggregationsOptions.externalRefresh  When running a separate instance of Cube.js to refresh pre-aggregations in the background, this option can be set on the API instance to prevent it from trying to check for rollup data being current - it won't try to create or refresh them when this option is true

concurrency Maximum number of queries to be processed simultaneosly. For drivers with connection pool CUBEJS_DB_MAX_POOL should be adjusted accordingly.  2

continueWaitTimeout Long polling interval 5

executionTimeout  Total timeout of single query 600

orphanedTimeout Query will be marked for cancellation if not requested during this period.  120

heartBeatInterval Worker heartbeat interval. If 4*heartBeatInterval time passes without reporting, the query gets cancelled.  30