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 log = logger ?? print;

  log('📋 [Queue] Starting job: ${context.job.displayName}');

  try {
    await next();

    log('✅ [Queue] Job completed: ${context.job.displayName} (${context.elapsed.inMilliseconds}ms)');
  } catch (e) {
    log('❌ [Queue] Job failed: ${context.job.displayName} - $e');
    rethrow;
  }
}