for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
declare(strict_types=1);
namespace Jellyfish\QueueRabbitMq;
use Jellyfish\Queue\DestinationInterface;
use Jellyfish\Queue\MessageInterface;
class QueueConsumer extends AbstractConsumer
{
/**
* @param \Jellyfish\Queue\DestinationInterface $destination
*
* @return \Jellyfish\Queue\MessageInterface|null
*/
public function receiveMessage(DestinationInterface $destination): ?MessageInterface
$this->connection->createQueue($destination);
return $this->doReceiveMessage($destination);
}
* @param int $limit
* @return \Jellyfish\Queue\MessageInterface[]
public function receiveMessages(DestinationInterface $destination, int $limit): array
$receivedMessages = [];
for ($i = 0; $i < $limit; $i++) {
$receivedMessage = $this->doReceiveMessage($destination);
if ($receivedMessage === null) {
return $receivedMessages;
$receivedMessages[] = $receivedMessage;
jellyfishphp /
jellyfish
