function drush_queue_ui_queue_process_all in Queue UI 8.2

Process all queues

File

./queue_ui.drush.inc, line 53

Code

function drush_queue_ui_queue_process_all() {
  $operations = [];
  $queues = \Drupal::service('plugin.manager.queue_worker')
    ->getDefinitions();

  // Add operations for each queue
  foreach ($queues as $queue_name => $queue_definition) {
    $operations[] = [
      '\\Drupal\\queue_ui\\QueueUIBatch::step',
      [
        $queue_name,
      ],
    ];
  }

  // Start batch process
  _queue_ui_start_batch($operations);
}