recordFailure method

  1. @override
Future<void> recordFailure({
  1. required String id,
  2. required String jobType,
  3. required Map<String, dynamic> payload,
  4. required dynamic error,
  5. required int attempts,
  6. StackTrace? stackTrace,
  7. Map<String, dynamic>? metadata,
})
override

Record a job failure

Implementation

@override
Future<void> recordFailure({
  required String id,
  required String jobType,
  required Map<String, dynamic> payload,
  required dynamic error,
  required int attempts,
  StackTrace? stackTrace,
  Map<String, dynamic>? metadata,
}) async {
  final failedJob = FailedJob(
    id: id,
    jobType: jobType,
    payload: payload,
    error: error.toString(),
    stackTrace: stackTrace?.toString(),
    failedAt: DateTime.now(),
    attempts: attempts,
    metadata: metadata,
  );

  await _dlq.store(failedJob);
}