DatabaseQueueDriver constructor

DatabaseQueueDriver({
  1. required DatabaseAdapter db,
  2. String table = 'kronix_jobs',
  3. String? workerId,
})

Creates a new DatabaseQueueDriver.

db - The database adapter to use. table - The table name (default: kronix_jobs). workerId - A unique ID for this worker instance (for lock ownership).

Implementation

DatabaseQueueDriver({
  required DatabaseAdapter db,
  String table = 'kronix_jobs',
  String? workerId,
})  : _db = db,
      _table = table,
      workerId = workerId ?? 'worker_${DateTime.now().millisecondsSinceEpoch}';