Flexible.php in Advanced Queue 8

Namespace

Drupal\advancedqueue_test\Plugin\AdvancedQueue\JobType

File

tests/modules/advancedqueue_test/src/Plugin/AdvancedQueue/JobType/Flexible.php

<?php

namespace Drupal\advancedqueue_test\Plugin\AdvancedQueue\JobType;

use Drupal\advancedqueue\Job;
use Drupal\advancedqueue\JobResult;
use Drupal\advancedqueue\Plugin\AdvancedQueue\JobType\JobTypeBase;

/**
 * Flexible job type.
 *
 * @AdvancedQueueJobType(
 *   id = "flexible",
 *   label = @Translation("Flexible"),
 * )
 */
class Flexible extends JobTypeBase {

  /**
   * {@inheritdoc}
   */
  public function process(Job $job) {
    $payload = $job
      ->getPayload();
    if (!empty($payload['expected_exception'])) {
      throw new \Exception($payload['expected_exception']);
    }
    return new JobResult($payload['expected_state'], $payload['expected_message'], isset($payload['max_retries']) ? $payload['max_retries'] : NULL, isset($payload['retry_delay']) ? $payload['retry_delay'] : NULL);
  }

}

Classes

Name	Description
Flexible	Flexible job type.