foreach ($products as $index => $product) {
  $this->messageQueue->push(new DelayedMessage('product.validate_stock', [
    'product' => $product['id']
  ], $index);
}

$this->messageQueue->flush();