thecodingmachine /
oo-amqp-client
| @@ 302-309 (lines=8) @@ | ||
| 299 | } |
|
| 300 | } |
|
| 301 | ||
| 302 | public function publish(Message $message, $routingKey, $mandatory = false, |
|
| 303 | $immediate = false, |
|
| 304 | $ticket = null) |
|
| 305 | { |
|
| 306 | $channel = $this->client->getChannel(); |
|
| 307 | ||
| 308 | $channel->basic_publish($message->toAMQPMessage(), $this->name, $routingKey, $mandatory, $immediate, $ticket); |
|
| 309 | } |
|
| 310 | } |
|
| 311 | ||
| @@ 578-585 (lines=8) @@ | ||
| 575 | * @param bool $immediate |
|
| 576 | * @param null $ticket |
|
| 577 | */ |
|
| 578 | public function publish(Message $message, $mandatory = false, |
|
| 579 | $immediate = false, |
|
| 580 | $ticket = null) |
|
| 581 | { |
|
| 582 | $channel = $this->client->getChannel(); |
|
| 583 | ||
| 584 | $channel->basic_publish($message->toAMQPMessage(), '', $this->name, $mandatory, $immediate, $ticket); |
|
| 585 | } |
|
| 586 | } |
|
| 587 | ||
