| Conditions | 2 | 
| Paths | 4 | 
| Total Lines | 16 | 
| Code Lines | 11 | 
| Lines | 0 | 
| Ratio | 0 % | 
| Changes | 0 | ||
| 1 | <?php | ||
| 40 | public function send(MessageInterface $message): MessageSendInterface | ||
| 41 |     { | ||
| 42 |         try { | ||
| 43 | $channel = $this->connection->channel(); | ||
| 44 | $channel->queue_declare($this->queue, false, false, false, false); | ||
| 45 | $channel->basic_publish(new AMQPMessage($message->toJson()), '', $this->queue); | ||
| 46 |         } catch (\Exception $e) { | ||
| 47 | throw new MessageSendException( | ||
| 48 |                 MessageSendException::MESSAGE_SEND_FAILED.'('.$e->getMessage().')', | ||
| 49 | MessageSendException::CODE_SEND_FAILED, | ||
| 50 | $e | ||
| 51 | ); | ||
| 52 | } | ||
| 53 | |||
| 54 | return $this; | ||
| 55 | } | ||
| 56 | } | ||
| 57 |