for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace Saxulum\MessageQueue;
abstract class AbstractMessageReceive implements MessageReceiveInterface
{
/**
* @return array
*
* @throws MessageReceiveException
*/
public function receiveAll(): array
$messages = [];
while (null !== $message = $this->receive()) {
$messages[] = $message;
}
return $messages;
saxulum /
saxulum-message-queue
