dispatchAfter method

Future<String> dispatchAfter(
  1. Duration delay,
  2. Job job
)

Dispatches a job with a delay before it becomes available.

Implementation

Future<String> dispatchAfter(Duration delay, Job job) async {
  job.availableAt = DateTime.now().add(delay);
  await driver.push(job, job.queue);
  metrics.recordDispatch();
  Logger.staticInfo('📤 Dispatched [${job.name}] to queue "${job.queue}" (available in ${delay.inSeconds}s)');
  return job.id;
}