enl /
amqpworkers
| Conditions | 3 |
| Paths | 3 |
| Total Lines | 14 |
| Code Lines | 8 |
| Lines | 0 |
| Ratio | 0 % |
| Changes | 1 | ||
| Bugs | 0 | Features | 0 |
| 1 | <?php |
||
| 13 | public function produce($messages) |
||
| 14 | { |
||
| 15 | $channel = $this->getChannel(); |
||
| 16 | |||
| 17 | foreach ($messages as $payload) { |
||
| 18 | if ($this->isExchange()) { |
||
| 19 | $channel->batch_basic_publish($this->createMessage($payload), $this->exchange->getName()); |
||
| 20 | } else { |
||
| 21 | $channel->batch_basic_publish($this->createMessage($payload), '', $this->queue->getName()); |
||
| 22 | } |
||
| 23 | } |
||
| 24 | |||
| 25 | $channel->publish_batch(); |
||
| 26 | } |
||
| 27 | |||
| 29 |
