PhpAmqpLib/Channel/AMQPChannel.php
public function wait_for_pending_acks($timeout = 0)
    {
        $functions = array(
            $this->waitHelper->get_wait('basic.ack'),
            $this->waitHelper->get_wait('basic.nack'),
        );

        while (count($this->published_messages) !== 0) {
            if ($timeout > 0) {
                $this->wait($functions, true, $timeout);
            } else {
                $this->wait($functions);
            }
        }
    }
public function wait_for_pending_acks($timeout = 0)
    {
        $functions = array(
            $this->waitHelper->get_wait('basic.ack'),
            $this->waitHelper->get_wait('basic.nack'),
        );

        while (count($this->published_messages) !== 0) {
            if ($timeout > 0) {
                $this->wait($functions, true, $timeout);
            } else {
                $this->wait($functions);
            }
        }
    }
public function wait_for_pending_acks ( $ timeout = 0 ) { $ functions = array ( $ this -> waitHelper -> get_wait ( 'basic.ack' ) , $ this -> waitHelper -> get_wait ( 'basic.nack' ) , ) ; while ( count ( $ this -> published_messages ) !== 0 ) { if ( $ timeout > 0 ) { $ this -> wait ( $ functions , true , $ timeout ) ; } else { $ this -> wait ( $ functions ) ; } } }
Waits for pending acks and nacks from the server.
If there are no pending acks, the method returns immediately

@param int $timeout Waits until $timeout value is reached
Waits for pending acks and nacks from the server . If there are no pending acks the method returns immediately