Saxulum\MessageQueue\Redis\RedisReceive::receive()

Complexity

Conditions	3
Paths	4

Size

Total Lines	19
Code Lines	11

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    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
            );
        }
    }
}