PhpAmqpLib/Channel/AMQPChannel.php
public function basic_cancel($consumer_tag, $nowait = false, $noreturn = false)
    {
        list($class_id, $method_id, $args) = $this->protocolWriter->basicCancel($consumer_tag, $nowait);
        $this->send_method_frame(array($class_id, $method_id), $args);

        if ($nowait || $noreturn) {
            unset($this->callbacks[$consumer_tag]);
            return $consumer_tag;
        }

        return $this->wait(array(
            $this->waitHelper->get_wait('basic.cancel_ok')
        ), false, $this->channel_rpc_timeout);
    }
public function basic_cancel($consumer_tag, $nowait = false, $noreturn = false)
    {
        list($class_id, $method_id, $args) = $this->protocolWriter->basicCancel($consumer_tag, $nowait);
        $this->send_method_frame(array($class_id, $method_id), $args);

        if ($nowait || $noreturn) {
            unset($this->callbacks[$consumer_tag]);
            return $consumer_tag;
        }

        return $this->wait(array(
            $this->waitHelper->get_wait('basic.cancel_ok')
        ), false, $this->channel_rpc_timeout);
    }
public function basic_cancel ( $ consumer_tag , $ nowait = false , $ noreturn = false ) { list ( $ class_id , $ method_id , $ args ) = $ this -> protocolWriter -> basicCancel ( $ consumer_tag , $ nowait ) ; $ this -> send_method_frame ( array ( $ class_id , $ method_id ) , $ args ) ; if ( $ nowait || $ noreturn ) { unset ( $ this -> callbacks [ $ consumer_tag ] ) ; return $ consumer_tag ; } return $ this -> wait ( array ( $ this -> waitHelper -> get_wait ( 'basic.cancel_ok' ) ) , false , $ this -> channel_rpc_timeout ) ; }
Ends a queue consumer

@param string $consumer_tag
@param bool $nowait
@param bool $noreturn
@throws \PhpAmqpLib\Exception\AMQPTimeoutException if the specified operation timeout was exceeded
@return mixed
Ends a queue consumer