handle method

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

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 jobId = context.metadata['job_id'] as String?;
  if (jobId == null) {
    await next();
    return;
  }

  final now = DateTime.now();
  final lastProcessed = _processedJobs[jobId];

  if (lastProcessed != null && now.difference(lastProcessed) < window) {
    // Skip duplicate job
    return;
  }

  _cleanExpiredEntries(now);
  _ensureCapacity(jobId);
  _processedJobs[jobId] = now;

  await next();
}