RedisStorageDriver constructor

RedisStorageDriver({
  1. required DriverConfig config,
  2. QueueMetrics? metrics,
  3. FailedJobHandler? dlqHandler,
  4. QueueMiddlewarePipeline? middleware,
  5. String? host,
  6. int? port,
  7. String? password,
  8. String? queueName,
  9. Set<String>? allowedJobTypes,
  10. int maxPayloadDepth = 10,
  11. int maxPayloadNodes = 2000,
  12. int maxSerializedJobBytes = 1024 * 1024,
})

Implementation

RedisStorageDriver({
  required super.config,
  super.metrics,
  super.dlqHandler,
  super.middleware,
  String? host,
  int? port,
  String? password,
  String? queueName,
  Set<String>? allowedJobTypes,
  int maxPayloadDepth = 10,
  int maxPayloadNodes = 2000,
  int maxSerializedJobBytes = 1024 * 1024,
}) : host =
         host ??
         config.driverSpecificConfig['host'] as String? ??
         'localhost',
     port = port ?? config.driverSpecificConfig['port'] as int? ?? 6379,
     password =
         password ?? config.driverSpecificConfig['password'] as String?,
     queueName =
         queueName ??
         config.driverSpecificConfig['queueName'] as String? ??
         'default',
     _allowedJobTypes =
         allowedJobTypes ??
         _parseAllowedJobTypes(
           config.driverSpecificConfig['allowedJobTypes'],
         ),
     _maxPayloadDepth = maxPayloadDepth,
     _maxPayloadNodes = maxPayloadNodes,
     _maxSerializedJobBytes = maxSerializedJobBytes;