clear method

void clear()

Clear all messages from the queue

Implementation

void clear() {
  int totalCleared = 0;
  for (final queue in _priorityQueues) {
    totalCleared += queue.length;
    queue.clear();
  }
  _totalQueued = 0;
  logger.info('Cleared $totalCleared messages from queue');
}