| Total Complexity | 6 |
| Total Lines | 82 |
| Duplicated Lines | 0 % |
| Changes | 1 | ||
| Bugs | 0 | Features | 1 |
| 1 | <?php |
||
| 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() |
||
| 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) |
||
| 97 | } |
||
| 98 | } |
||
| 99 |