CallbackInvoker.php

Go to the documentation of this file.

<?php
namespace Magento\Framework\MessageQueue;

class CallbackInvoker
{
    public function invoke(QueueInterface $queue, $maxNumberOfMessages, $callback)
    {
        for ($i = $maxNumberOfMessages; $i > 0; $i--) {
            do {
                $message = $queue->dequeue();
            } while ($message === null && (sleep(1) === 0));
            $callback($message);
        }
    }
}