videlalvaro /
php-amqplib
| @@ 478-496 (lines=19) @@ | ||
| 475 | * @param null $ticket |
|
| 476 | * @return mixed |
|
| 477 | */ |
|
| 478 | public function exchange_unbind($destination, $source, $routing_key = '', $arguments = null, $ticket = null) |
|
| 479 | { |
|
| 480 | $arguments = $this->getArguments($arguments); |
|
| 481 | $ticket = $this->getTicket($ticket); |
|
| 482 | ||
| 483 | list($class_id, $method_id, $args) = $this->protocolWriter->exchangeUnbind( |
|
| 484 | $ticket, |
|
| 485 | $destination, |
|
| 486 | $source, |
|
| 487 | $routing_key, |
|
| 488 | $arguments |
|
| 489 | ); |
|
| 490 | ||
| 491 | $this->send_method_frame(array($class_id, $method_id), $args); |
|
| 492 | ||
| 493 | return $this->wait(array( |
|
| 494 | $this->waitHelper->get_wait('exchange.unbind_ok') |
|
| 495 | )); |
|
| 496 | } |
|
| 497 | ||
| 498 | /** |
|
| 499 | * Confirms unbind successful |
|
| @@ 558-576 (lines=19) @@ | ||
| 555 | * @param null $ticket |
|
| 556 | * @return mixed |
|
| 557 | */ |
|
| 558 | public function queue_unbind($queue, $exchange, $routing_key = '', $arguments = null, $ticket = null) |
|
| 559 | { |
|
| 560 | $arguments = $this->getArguments($arguments); |
|
| 561 | $ticket = $this->getTicket($ticket); |
|
| 562 | ||
| 563 | list($class_id, $method_id, $args) = $this->protocolWriter->queueUnbind( |
|
| 564 | $ticket, |
|
| 565 | $queue, |
|
| 566 | $exchange, |
|
| 567 | $routing_key, |
|
| 568 | $arguments |
|
| 569 | ); |
|
| 570 | ||
| 571 | $this->send_method_frame(array($class_id, $method_id), $args); |
|
| 572 | ||
| 573 | return $this->wait(array( |
|
| 574 | $this->waitHelper->get_wait('queue.unbind_ok') |
|
| 575 | )); |
|
| 576 | } |
|
| 577 | ||
| 578 | /** |
|
| 579 | * Confirms unbind successful |
|
