diff --git a/Persister/QueuePagerPersister.php b/Persister/QueuePagerPersister.php index 91ef724..f45cb92 100644 --- a/Persister/QueuePagerPersister.php +++ b/Persister/QueuePagerPersister.php @@ -93,6 +93,9 @@ public function insert(PagerInterface $pager, array $options = array()) ])); $message->setReplyTo($replyQueue->getQueueName()); + // Because of https://github.com/php-enqueue/enqueue-dev/issues/907 + \usleep(10); + $producer->send($queue, $message); $page++;