Passed
Push — master ( 8c18f6...242f2e )
by Mihai
07:54
created

AMQPEvent   A

Complexity

Total Complexity 6

Size/Duplication

Total Lines 82
Duplicated Lines 0 %

Importance

Changes 1
Bugs 0 Features 1
Metric Value
eloc 19
dl 0
loc 82
rs 10
c 1
b 0
f 1
wmc 6

6 Methods

Rating   Name   Duplication   Size   Complexity  
A getAMQPMessage() 0 3 1
A setProducer() 0 5 1
A getProducer() 0 3 1
A setAMQPMessage() 0 5 1
A getConsumer() 0 3 1
A setConsumer() 0 5 1
1
<?php
2
3
namespace OldSound\RabbitMqBundle\Event;
4
5
use OldSound\RabbitMqBundle\RabbitMq\Consumer;
6
use OldSound\RabbitMqBundle\RabbitMq\Producer;
7
use PhpAmqpLib\Message\AMQPMessage;
8
9
/**
10
 * Class AMQPEvent
11
 *
12
 * @package OldSound\RabbitMqBundle\Event
13
 * @codeCoverageIgnore
14
 */
15
class AMQPEvent extends AbstractAMQPEvent
16
{
17
    public const ON_CONSUME                = 'on_consume';
18
    public const ON_IDLE                   = 'on_idle';
19
    public const BEFORE_PROCESSING_MESSAGE = 'before_processing';
20
    public const AFTER_PROCESSING_MESSAGE  = 'after_processing';
21
    public const BEFORE_PUBLISH_MESSAGE = 'before_publishing';
22
    public const AFTER_PUBLISH_MESSAGE  = 'after_publishing';
23
24
    /**
25
     * @var AMQPMessage
26
     */
27
    protected $AMQPMessage;
28
29
    /**
30
     * @var Consumer
31
     */
32
    protected $consumer;
33
34
    /**
35
     * @var Producer
36
     */
37
    protected $producer;
38
39
    /**
40
     * @return AMQPMessage
41
     */
42
    public function getAMQPMessage()
43
    {
44
        return $this->AMQPMessage;
45
    }
46
47
    /**
48
     * @param AMQPMessage $AMQPMessage
49
     *
50
     * @return AMQPEvent
51
     */
52
    public function setAMQPMessage(AMQPMessage $AMQPMessage)
53
    {
54
        $this->AMQPMessage = $AMQPMessage;
55
56
        return $this;
57
    }
58
59
    /**
60
     * @return Consumer
61
     */
62
    public function getConsumer()
63
    {
64
        return $this->consumer;
65
    }
66
67
    /**
68
     * @param Consumer $consumer
69
     *
70
     * @return AMQPEvent
71
     */
72
    public function setConsumer(Consumer $consumer)
73
    {
74
        $this->consumer = $consumer;
75
76
        return $this;
77
    }
78
79
    /**
80
     * @return Producer
81
     */
82
    public function getProducer()
83
    {
84
        return $this->producer;
85
    }
86
87
    /**
88
     * @param Producer $producer
89
     *
90
     * @return AMQPEvent
91
     */
92
    public function setProducer(Producer $producer)
93
    {
94
        $this->producer = $producer;
95
96
        return $this;
97
    }
98
}
99