bakura10 · December 2, 2018 11:49
diff --git a/test.php b/test.php
 foreach ($products as $index => $product) {
  $this->messageQueue->push(new DelayedMessage('product.validate_stock', [
    'product' => $product['id']
  ], $index);
 }

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

	$this->messageQueue->flush();