clearDeadLetters method

  1. @override
Future<void> clearDeadLetters()
override

Clears the dead letter queue.

Implementation

@override
Future<void> clearDeadLetters() async {
  await _db.query('''
    DELETE FROM $_table WHERE status = 'failed'
  ''');
}