Completed
Push — master ( 1fe8c2...13f8a0 )
by Dominik
02:39
created

RabbitMQReceive::__construct()   A

Complexity

Conditions 1
Paths 1

Size

Total Lines 6
Code Lines 4

Duplication

Lines 0
Ratio 0 %

Importance

Changes 0
Metric Value
dl 0
loc 6
rs 9.4285
c 0
b 0
f 0
cc 1
eloc 4
nc 1
nop 3
1
<?php
2
3
namespace Saxulum\MessageQueue\RabbitMQ;
4
5
use PhpAmqpLib\Connection\AMQPStreamConnection;
6
use PhpAmqpLib\Message\AMQPMessage;
7
use Saxulum\MessageQueue\AbstractMessageReceive;
8
use Saxulum\MessageQueue\MessageInterface;
9
use Saxulum\MessageQueue\MessageReceiveException;
10
11
final class RabbitMQReceive extends AbstractMessageReceive
12
{
13
    /**
14
     * @var string
15
     */
16
    private $messageClass;
17
18
    /**
19
     * @var AMQPStreamConnection
20
     */
21
    private $connection;
22
23
    /**
24
     * @var string
25
     */
26
    private $queue;
27
28
    /**
29
     * @param string               $messageClass
30
     * @param AMQPStreamConnection $connection
31
     * @param string               $queue
32
     */
33
    public function __construct(string $messageClass, AMQPStreamConnection $connection, string $queue)
34
    {
35
        $this->messageClass = $messageClass;
36
        $this->connection = $connection;
37
        $this->queue = $queue;
38
    }
39
40
    /**
41
     * @return MessageInterface|null
42
     *
43
     * @throws MessageReceiveException
44
     */
45
    public function receive()
46
    {
47
        try {
48
            $channel = $this->connection->channel();
49
            $channel->queue_declare($this->queue, false, false, false, false);
50
51
            /** @var AMQPMessage $rabbitMQMessage */
52
            if (null === $rabbitMQMessage = $channel->basic_get($this->queue, true)) {
53
                return null;
54
            }
55
56
            /** @var MessageInterface $messageClass */
57
            $messageClass = $this->messageClass;
58
59
            return $messageClass::fromJson($rabbitMQMessage->body);
60
        } catch (\Exception $e) {
61
            throw new MessageReceiveException(
62
                MessageReceiveException::MESSAGE_RECEIVE_FAILED.'('.$e->getMessage().')',
63
                MessageReceiveException::CODE_RECEIVE_FAILED,
64
                $e
65
            );
66
        }
67
    }
68
}
69