Completed
Push — master ( c6635f...c8eea5 )
by Claude
03:23
created

InMemory::getQueue()   A

Complexity

Conditions 1
Paths 1

Size

Total Lines 4
Code Lines 2

Duplication

Lines 0
Ratio 0 %

Importance

Changes 0
Metric Value
dl 0
loc 4
c 0
b 0
f 0
rs 10
cc 1
eloc 2
nc 1
nop 1
1
<?php
2
3
namespace Puzzle\AMQP\Clients;
4
5
use Puzzle\AMQP\Client;
6
use Puzzle\AMQP\WritableMessage;
7
use Puzzle\AMQP\Messages\InMemoryJson;
8
use Psr\Log\NullLogger;
9
use Puzzle\AMQP\Collections;
10
11
class InMemory implements Client
12
{
13
    use \Psr\Log\LoggerAwareTrait;
14
15
    private
16
        $sentMessages;
1 ignored issue
show
Coding Style introduced by
The visibility should be declared for property $sentMessages.

The PSR-2 coding standard requires that all properties in a class have their visibility explicitly declared. If you declare a property using

class A {
    var $property;
}

the property is implicitly global.

To learn more about the PSR-2, please see the PHP-FIG site on the PSR-2.

Loading history...
17
18
    public function __construct()
19
    {
20
        $this->sentMessages = array();
21
        $this->logger = new NullLogger();
22
    }
23
24
    public function publish($exchangeName, WritableMessage $message)
25
    {
26
        $this->saveMessage($exchangeName, $message);
27
    }
28
29
    public function getQueue($queueName)
30
    {
31
        throw new \RuntimeException('This AMQP Client must be used only for sending purpose');
32
    }
33
34
    public function getExchange($exchangeName)
35
    {
36
        throw new \RuntimeException('This AMQP Client must be used only for sending purpose');
37
    }
38
39
    private function saveMessage($exchangeName, WritableMessage $message)
40
    {
41
        $this->sentMessages[] = array(
42
            'exchange' => $exchangeName,
43
            'message' => $message
44
        );
45
    }
46
47
    public function getSentMessages()
48
    {
49
        return $this->sentMessages;
50
    }
51
52
    public function dropSentMessages()
53
    {
54
        $this->sentMessages = array();
55
56
        return $this;
57
    }
58
}