php-amqplib / php-amqplib

     * @param  callable $callback

     * @throws \InvalidArgumentException if $callback is not callable

     */

    public function set_return_listener($callback)

    {

        if (!is_callable($callback)) {

            throw new \InvalidArgumentException(sprintf(

                'Given callback "%s" should be callable. %s type was given.',

                $callback,

                gettype($callback)

            ));

        }

        $this->basic_return_callback = $callback;

    }

    /**

     * Sets a handler which called for any message nack'ed by the server, with the AMQPMessage as first argument.

     * @param callable $callback

     * @throws \InvalidArgumentException

     */

    public function set_nack_handler($callback)

    {

        if (!is_callable($callback)) {

            throw new \InvalidArgumentException(sprintf(

                'Given callback "%s" should be callable. %s type was given.',

                $callback,

                gettype($callback)

            ));

        }

        $this->nack_handler = $callback;

    }

    /**

     * Sets a handler which called for any message ack'ed by the server, with the AMQPMessage as first argument.

     * @param callable $callback

     * @throws \InvalidArgumentException

     */

    public function set_ack_handler($callback)

    {

        if (!is_callable($callback)) {

            throw new \InvalidArgumentException(sprintf(

                'Given callback "%s" should be callable. %s type was given.',

                $callback,

                gettype($callback)

            ));

        }

        $this->ack_handler = $callback;

    }

}