You are here

interface PushQueueProcessorInterface in Salesforce Suite 8.4

Same name and namespace in other branches
  1. 8.3 modules/salesforce_push/src/PushQueueProcessorInterface.php \Drupal\salesforce_push\PushQueueProcessorInterface
  2. 5.0.x modules/salesforce_push/src/PushQueueProcessorInterface.php \Drupal\salesforce_push\PushQueueProcessorInterface

Interface implemented by Salesforce Push Queue Processors.

Push Queue Processors are responsible for asynchronously processing a set of push queue items (during cron).

Hierarchy

Expanded class hierarchy of PushQueueProcessorInterface

All classes that implement PushQueueProcessorInterface

2 files declare their use of PushQueueProcessorInterface
PushQueueTest.php in modules/salesforce_push/tests/src/Unit/PushQueueTest.php
Rest.php in modules/salesforce_push/src/Plugin/SalesforcePushQueueProcessor/Rest.php

File

modules/salesforce_push/src/PushQueueProcessorInterface.php, line 15

Namespace

Drupal\salesforce_push
View source
interface PushQueueProcessorInterface extends ContainerFactoryPluginInterface {

  /**
   * Process an array of push queue items.
   *
   * When an item is successfully processed, delete the item from queue via
   * PushQueue::deleteItem().
   *
   * @param array $items
   *   The items to process.
   *
   * @throws \Drupal\Core\Queue\SuspendQueueException
   *   Indicate that processing for this queue should not continue.
   *   Move on to the next queue.
   *   Items should be released.
   *
   * @throws \Drupal\Core\Queue\RequeueException
   *   Indicate that processing for this set of items failed.
   *   Processing for this queue should continue.
   *   Items should be released.
   *
   * @throws \Exception
   *   Indicate any other condition. Processing for this queue should continue.
   *   Items should not be released.
   */
  public function process(array $items);

}

Members

Namesort descending Modifiers Type Description Overrides
ContainerFactoryPluginInterface::create public static function Creates an instance of the plugin. 112
PushQueueProcessorInterface::process public function Process an array of push queue items. 1