function CronSuspendQueueDelayTest::testSuspendQueue

Tests a queue is reprocessed again after other queues.

Two queues are created:

• test_worker_a.
• test_worker_b.

Queues and items are processed:

• test_worker_a:
  • item throws SuspendQueueException with 2.0 delay.
• test_worker_b:
  • item executes normally.
• test_worker_a:
  • item throws SuspendQueueException with 3.0 delay.
• test_worker_a:
  • no items remaining, quits.

File

core/tests/Drupal/Tests/Core/Cron/CronSuspendQueueDelayTest.php, line 126

Class

CronSuspendQueueDelayTest

Test Cron handling of suspended queues with a delay.

Namespace

Code

public function testSuspendQueue() : void {
  [
    'queue_factory' => $queueFactory,
    'queue_manager' => $queueManager,
    'time' => $time,
  ] = $this->cronConstructorArguments;
  $cron = $this->getMockBuilder(Cron::class)
    ->onlyMethods([
    'usleep',
  ])
    ->setConstructorArgs($this->cronConstructorArguments)
    ->getMock();
  $delays = [
    2000000,
    3000000,
  ];
  $cron->expects($this->exactly(count($delays)))
    ->method('usleep')
    ->with($this->callback(function (int $delay) use (&$delays) : bool {
    return array_shift($delays) === $delay;
  }));
  $queueManager->expects($this->once())
    ->method('getDefinitions')
    ->willReturn([
    'test_worker_a' => [
      'id' => 'test_worker_a',
      'cron' => [
        'time' => 300,
      ],
    ],
    'test_worker_b' => [
      'id' => 'test_worker_b',
      'cron' => [
        'time' => 300,
      ],
    ],
  ]);
  $queueA = $this->createMock(QueueInterface::class);
  $queueB = $this->createMock(QueueInterface::class);
  $queueFactory->expects($this->exactly(2))
    ->method('get')
    ->willReturnMap([
    [
      'test_worker_a',
      FALSE,
      $queueA,
    ],
    [
      'test_worker_b',
      FALSE,
      $queueB,
    ],
  ]);
  // Expect this queue to be processed twice.
  $queueA->expects($this->exactly(3))
    ->method('claimItem')
    ->willReturnOnConsecutiveCalls((object) [
    'data' => 'test_data_a1',
  ], (object) [
    'data' => 'test_data_a2',
  ], FALSE);
  // Expect this queue to be processed once.
  $queueB->expects($this->exactly(2))
    ->method('claimItem')
    ->willReturnOnConsecutiveCalls((object) [
    'data' => 'test_data_b1',
  ], FALSE);
  $queueManager->expects($this->any())
    ->method('createInstance')
    ->willReturnMap([
    [
      'test_worker_a',
      [],
      $this->workerA,
    ],
    [
      'test_worker_b',
      [],
      $this->workerB,
    ],
  ]);
  $this->workerA
    ->expects($this->exactly(2))
    ->method('processItem')
    ->with($this->anything())
    ->willReturnOnConsecutiveCalls($this->throwException(new SuspendQueueException('', 0, NULL, 2.0)), $this->throwException(new SuspendQueueException('', 0, NULL, 3.0)));
  $this->workerB
    ->expects($this->once())
    ->method('processItem')
    ->with('test_data_b1');
  $time->expects($this->any())
    ->method('getCurrentTime')
    ->willReturn(60);
  $cron->run();
}