class UniqueQueueItem in TMGMT Extension Suite 8.2

Hierarchy

• class \Drupal\tmgmt_extension_suit\Utils\UniqueQueueItem

1 file declares its use of UniqueQueueItem

JobCheckStatus.php in src/Plugin/QueueWorker/JobCheckStatus.php

1 string reference to 'UniqueQueueItem'

tmgmt_extension_suit.services.yml in ./tmgmt_extension_suit.services.yml

tmgmt_extension_suit.services.yml

1 service uses UniqueQueueItem

tmgmt_extension_suit.utils.queue_unique_item in ./tmgmt_extension_suit.services.yml

Drupal\tmgmt_extension_suit\Utils\UniqueQueueItem

File

src/Utils/UniqueQueueItem.php, line 14

Contains QueueUniqueItem service class.

Namespace

Drupal\tmgmt_extension_suit\Utils

class UniqueQueueItem {

  /**
   * @var \Drupal\Core\Queue\QueueFactory
   */
  private $queueFactory;

  /**
   * @var \Psr\Log\LoggerInterface
   */
  private $logger;

  /**
   * @var \Drupal\Core\Database\Connection
   */
  private $databaseConnection;
  public function __construct(QueueFactory $queue_factory, LoggerInterface $logger, Connection $database_connection) {
    $this->queueFactory = $queue_factory;
    $this->logger = $logger;
    $this->databaseConnection = $database_connection;
  }

  /**
   * Adds item into a queue only if it's unique.
   *
   * @param string $queue_name
   *   Queue name.
   * @param array $data
   *   Data to be added.
   * @param bool $force
   *   Force adding item into the queue.
   */
  public function addItem($queue_name, $data, $force = FALSE) {
    $serialized_data = serialize($data);
    if (!$force) {
      $count = $this->databaseConnection
        ->select('queue', 'q')
        ->condition('q.name', $queue_name)
        ->condition('q.data', $serialized_data)
        ->countQuery()
        ->execute()
        ->fetchField();
      if ($count != 0) {
        return;
      }
    }
    $result = $this->queueFactory
      ->get($queue_name)
      ->createItem($data);
    if ($result) {
      $this->logger
        ->info('New unique item has been added into the "@queue" queue. Serialized queue item: @item, forced: @forced.', [
        '@queue' => $queue_name,
        '@item' => $serialized_data,
        '@forced' => (int) $force,
      ]);
    }
  }

}

Members

Name	Modifiers	Type	Description	Overrides
UniqueQueueItem::$databaseConnection	private	property
UniqueQueueItem::$logger	private	property
UniqueQueueItem::$queueFactory	private	property
UniqueQueueItem::addItem	public	function	Adds item into a queue only if it's unique.
UniqueQueueItem::__construct	public	function