Completed
Push — master ( 4bf91f...d42076 )
by Nicolas
03:14
created

InMemory::getExchange()   A

Complexity

Conditions 1
Paths 1

Size

Total Lines 4
Code Lines 2

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 0
CRAP Score 2

Importance

Changes 0
Metric Value
c 0
b 0
f 0
dl 0
loc 4
ccs 0
cts 2
cp 0
rs 10
cc 1
eloc 2
nc 1
nop 1
crap 2
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 9
    public function __construct()
19
    {
20 9
        $this->sentMessages = array();
21 9
        $this->logger = new NullLogger();
22 9
    }
23
24 7
    public function publish($exchangeName, WritableMessage $message)
25
    {
26 7
        $this->saveMessage($exchangeName, $message);
27 7
    }
28
29 1
    public function getQueue($queueName)
30
    {
31 1
        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 7
    private function saveMessage($exchangeName, WritableMessage $message)
40
    {
41 7
        $this->sentMessages[] = array(
42 7
            'exchange' => $exchangeName,
43
            'message' => $message
44 7
        );
45 7
    }
46
47 7
    public function getSentMessages()
48
    {
49 7
        return $this->sentMessages;
50
    }
51
52 1
    public function dropSentMessages()
53
    {
54 1
        $this->sentMessages = array();
55
56 1
        return $this;
57
    }
58
}
59