retry method

  1. @override
Future<FailedJob?> retry(
  1. String id
)
override

Retry a failed job (returns the job for re-dispatch)

Implementation

@override
Future<FailedJob?> retry(String id) async {
  final job = await _dlq.get(id);
  if (job != null) {
    await _dlq.remove(id);
  }
  return job;
}