test.php

$variants = [];

foreach ($shopifyClient->getVariantsIterator(['fields' => 'id,inventory_quantity']) as $variant) {
  $variants[$variant['id']] = $variant['inventory_quantity'];
}

foreach ($products as $index => $product) {
  $delay = (int) ($index / 4);

  if ($product['quantity'] === $variants[$product['id']] {
    continue;
  }

  $this->messageQueue->push(new DelayedMessage('product.validate_stock', [
    'product' => $product['id']
  ], max($delay, 900));
}

$this->messageQueue->flush();