clear method

@override Future<void> clear()

Clear all jobs (for testing)

Implementation

@override
Future<void> clear() async {
  final command = await _getConnection();

  await command.send_object(['DEL', _mainQueue]);
  await command.send_object(['DEL', _delayedQueue]);
  await command.send_object(['DEL', _processingHash]);
  await command.send_object(['DEL', _failedQueue]);

  if (metrics != null) {
    metrics!.recordQueueDepth(0);
  }
}