videlalvaro / php-amqplib

     * @param AMQPReader $args

     * @throws AMQPRuntimeException

     */

    protected function basic_ack_from_server(AMQPReader $args)

    {

        $delivery_tag = $args->read_longlong();

        $multiple = (bool) $args->read_bit();

        if (false === 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.nack

     * @param AMQPReader $args

     * @throws AMQPRuntimeException

     */

    protected function basic_nack_from_server($args)

    {

        $delivery_tag = $args->read_longlong();

        $multiple = (bool) $args->read_bit();

        if (false === isset($this->published_messages[$delivery_tag])) {

            throw new AMQPRuntimeException(sprintf(

                'Server nack\'ed unknown delivery_tag "%s"',

                $delivery_tag

            ));

        }

        $this->internal_ack_handler($delivery_tag, $multiple, $this->nack_handler);

    }

    /**

     * Handles the deletion of messages from this->publishedMessages and dispatches them to the $handler