Version 1

[yaffs-website] / vendor / drush / drush / lib / Drush / Queue / Queue8.php

diff --git a/vendor/drush/drush/lib/Drush/Queue/Queue8.php b/vendor/drush/drush/lib/Drush/Queue/Queue8.php
new file mode 100644 (file)
index 0000000..7502b46
--- /dev/null
+++ b/vendor/drush/drush/lib/Drush/Queue/Queue8.php
@@ -0,0 +1,82 @@
+<?php
+
+namespace Drush\Queue;
+
+use Drush\Log\LogLevel;
+use Drupal\Core\Queue\QueueWorkerManager;
+use Drupal\Core\Queue\RequeueException;
+use Drupal\Core\Queue\SuspendQueueException;
+
+class Queue8 extends QueueBase {
+
+  /**
+   * @var \Drupal\Core\Queue\QueueWorkerManager
+   */
+  protected $workerManager;
+
+  /**
+   * Set the queue worker manager.
+   */
+  public function __construct(QueueWorkerManager $manager = NULL) {
+    $this->workerManager = $manager ?: \Drupal::service('plugin.manager.queue_worker');
+  }
+
+  /**
+   * {@inheritdoc}
+   */
+  public function getQueues() {
+    if (!isset(static::$queues)) {
+      static::$queues = array();
+      foreach ($this->workerManager->getDefinitions() as $name => $info) {
+        static::$queues[$name] = $info;
+      }
+    }
+    return static::$queues;
+  }
+
+  /**
+   * {@inheritdoc}
+   *
+   * @return \Drupal\Core\Queue\QueueInterface
+   */
+  public function getQueue($name) {
+    return \Drupal::queue($name);
+  }
+
+  /**
+   * {@inheritdoc}
+   */
+  public function run($name, $time_limit = 0) {
+    $worker = $this->workerManager->createInstance($name);
+    $end = time() + $time_limit;
+    $queue = $this->getQueue($name);
+    $count = 0;
+
+    while ((!$time_limit || time() < $end) && ($item = $queue->claimItem())) {
+      try {
+        drush_log(dt('Processing item @id from @name queue.', array('@name' => $name, '@id' => $item->item_id)), LogLevel::INFO);
+        $worker->processItem($item->data);
+        $queue->deleteItem($item);
+        $count++;
+      }
+      catch (RequeueException $e) {
+        // The worker requested the task to be immediately requeued.
+        $queue->releaseItem($item);
+      }
+      catch (SuspendQueueException $e) {
+        // If the worker indicates there is a problem with the whole queue,
+        // release the item and skip to the next queue.
+        $queue->releaseItem($item);
+        drush_set_error('DRUSH_SUSPEND_QUEUE_EXCEPTION', $e->getMessage());
+      }
+      catch (\Exception $e) {
+        // In case of any other kind of exception, log it and leave the item
+        // in the queue to be processed again later.
+        drush_set_error('DRUSH_QUEUE_EXCEPTION', $e->getMessage());
+      }
+    }
+
+    return $count;
+  }
+
+}