Worker constructor

Worker({
  1. required QueueDriver driver,
  2. List<String> queues = const ['default'],
  3. Duration pollInterval = const Duration(milliseconds: 500),
  4. int concurrency = 1,
  5. int maxJobsPerSecond = 0,
  6. QueueMetrics? metrics,
})

Implementation

Worker({
  required this.driver,
  this.queues = const ['default'],
  this.pollInterval = const Duration(milliseconds: 500),
  this.concurrency = 1,
  this.maxJobsPerSecond = 0,
  QueueMetrics? metrics,
}) : metrics = metrics ?? QueueMetrics();