Saxulum\MessageQueue\Redis\RedisReceive

Complexity

Total Complexity

6

Size/Duplication

Total Lines	69
Duplicated Lines	13.04 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	receive()	0	19	3
A	receiveAll()	9	9	2

<?php

namespace Saxulum\MessageQueue\Redis;

use Predis\ClientInterface;
use Saxulum\MessageQueue\MessageInterface;
use Saxulum\MessageQueue\MessageReceiveException;
use Saxulum\MessageQueue\MessageReceiveInterface;

final class RedisReceive implements MessageReceiveInterface
{
    /**
     * @var string
     */
    private $messageClass;

    /**
     * @var ClientInterface
     */
    private $redis;

    /**
     * @var string
     */
    private $list;

    /**
     * @param string          $messageClass
     * @param ClientInterface $redis
     * @param string          $list
     */
    public function __construct(string $messageClass, ClientInterface $redis, string $list)
    {
        $this->messageClass = $messageClass;
        $this->redis = $redis;
        $this->list = $list;
    }

    /**
     * @return MessageInterface|null
     *
     * @throws MessageReceiveException
     */
    public function receive()
    {
        try {
            if (null === $json = $this->redis->lpop($this->list)) {
                return null;
            }

            /** @var MessageInterface $messageClass */
            $messageClass = $this->messageClass;

            return $messageClass::fromJson($json);
        } catch (\Exception $e) {
            throw new MessageReceiveException(
                MessageReceiveException::MESSAGE_RECEIVE_FAILED.'('.$e->getMessage().')',
                MessageReceiveException::CODE_RECEIVE_FAILED,
                $e
            );
        }
    }

    /**
     * @return array
     *
     * @throws MessageReceiveException
     */
    public function receiveAll(): array

This method seems to be duplicated in your project.

    {
        $messages = [];
        while (null !== $message = $this->receive()) {
            $messages[] = $message;
        }

        return $messages;
    }
}