PhpAmqpLib/Channel/AMQPChannel.php
protected function basic_ack_from_server(AMQPReader $reader)
    {
        $delivery_tag = $reader->read_longlong();
        $multiple = (bool) $reader->read_bit();

        if (!isset($this->published_messages[$delivery_tag])) {
            throw new AMQPRuntimeException(sprintf(
                'Server ack\'ed unknown delivery_tag "%s"',
                $delivery_tag
            ));
        }

        $this->internal_ack_handler($delivery_tag, $multiple, $this->ack_handler);
    }
protected function basic_ack_from_server(AMQPReader $reader)
    {
        $delivery_tag = $reader->read_longlong();
        $multiple = (bool) $reader->read_bit();

        if (!isset($this->published_messages[$delivery_tag])) {
            throw new AMQPRuntimeException(sprintf(
                'Server ack\'ed unknown delivery_tag "%s"',
                $delivery_tag
            ));
        }

        $this->internal_ack_handler($delivery_tag, $multiple, $this->ack_handler);
    }
protected function basic_ack_from_server ( AMQPReader $ reader ) { $ delivery_tag = $ reader -> read_longlong ( ) ; $ multiple = ( bool ) $ reader -> read_bit ( ) ; if ( ! isset ( $ this -> published_messages [ $ delivery_tag ] ) ) { throw new AMQPRuntimeException ( sprintf ( 'Server ack\'ed unknown delivery_tag "%s"' , $ delivery_tag ) ) ; } $ this -> internal_ack_handler ( $ delivery_tag , $ multiple , $ this -> ack_handler ) ; }
Called when the server sends a basic.ack

@param AMQPReader $reader
@throws AMQPRuntimeException
Called when the server sends a basic . ack