@@ 387-410 (lines=24) @@ | ||
384 | * @param null $ticket |
|
385 | * @return mixed|null |
|
386 | */ |
|
387 | public function exchange_delete( |
|
388 | $exchange, |
|
389 | $if_unused = false, |
|
390 | $nowait = false, |
|
391 | $ticket = null |
|
392 | ) { |
|
393 | $ticket = $this->getTicket($ticket); |
|
394 | list($class_id, $method_id, $args) = $this->protocolWriter->exchangeDelete( |
|
395 | $ticket, |
|
396 | $exchange, |
|
397 | $if_unused, |
|
398 | $nowait |
|
399 | ); |
|
400 | ||
401 | $this->send_method_frame(array($class_id, $method_id), $args); |
|
402 | ||
403 | if ($nowait) { |
|
404 | return null; |
|
405 | } |
|
406 | ||
407 | return $this->wait(array( |
|
408 | $this->waitHelper->get_wait('exchange.delete_ok') |
|
409 | )); |
|
410 | } |
|
411 | ||
412 | /** |
|
413 | * Confirms deletion of an exchange |
|
@@ 700-714 (lines=15) @@ | ||
697 | * @param null $ticket |
|
698 | * @return mixed|null |
|
699 | */ |
|
700 | public function queue_purge($queue = '', $nowait = false, $ticket = null) |
|
701 | { |
|
702 | $ticket = $this->getTicket($ticket); |
|
703 | list($class_id, $method_id, $args) = $this->protocolWriter->queuePurge($ticket, $queue, $nowait); |
|
704 | ||
705 | $this->send_method_frame(array($class_id, $method_id), $args); |
|
706 | ||
707 | if ($nowait) { |
|
708 | return null; |
|
709 | } |
|
710 | ||
711 | return $this->wait(array( |
|
712 | $this->waitHelper->get_wait('queue.purge_ok') |
|
713 | )); |
|
714 | } |
|
715 | ||
716 | /** |
|
717 | * Confirms a queue purge |
|
@@ 846-859 (lines=14) @@ | ||
843 | * @param bool $noreturn |
|
844 | * @return mixed |
|
845 | */ |
|
846 | public function basic_cancel($consumer_tag, $nowait = false, $noreturn = false) |
|
847 | { |
|
848 | list($class_id, $method_id, $args) = $this->protocolWriter->basicCancel($consumer_tag, $nowait); |
|
849 | $this->send_method_frame(array($class_id, $method_id), $args); |
|
850 | ||
851 | if ($nowait || $noreturn) { |
|
852 | unset($this->callbacks[$consumer_tag]); |
|
853 | return $consumer_tag; |
|
854 | } |
|
855 | ||
856 | return $this->wait(array( |
|
857 | $this->waitHelper->get_wait('basic.cancel_ok') |
|
858 | )); |
|
859 | } |
|
860 | ||
861 | /** |
|
862 | * @param AMQPReader $args |