handle method

  1. @override
Future<void> handle(
  1. QueueJobContext context,
  2. Next next
)
override

Handle the job context Call next() to continue to the next middleware or job execution

Implementation

@override
Future<void> handle(QueueJobContext context, Next next) async {
  final startTime = DateTime.now();

  try {
    await next();
  } finally {
    final duration = DateTime.now().difference(startTime);
    context.addMetadata('processingTime', duration);
    onComplete?.call(context.job.displayName, duration);
  }
}