public function purge() {

        try {
            $this->channel->_getChannel()->queue_purge($this->name);
        } catch (AMQPRuntimeException $e) {
            throw new AMQPConnectionException($e->getMessage(), $e->getCode(), $e->getPrevious());
        } catch (Exception $e) {
            return false;
        }

        return true;
    }
public function purge() {

        try {
            $this->channel->_getChannel()->queue_purge($this->name);
        } catch (AMQPRuntimeException $e) {
            throw new AMQPConnectionException($e->getMessage(), $e->getCode(), $e->getPrevious());
        } catch (Exception $e) {
            return false;
        }

        return true;
    }
public function purge ( ) { try { $ this -> channel -> _getChannel ( ) -> queue_purge ( $ this -> name ) ; } catch ( AMQPRuntimeException $ e ) { throw new AMQPConnectionException ( $ e -> getMessage ( ) , $ e -> getCode ( ) , $ e -> getPrevious ( ) ) ; } catch ( Exception $ e ) { return false ; } return true ; }
Purge the contents of a queue.

@throws AMQPChannelException    If the channel is not open.
@throws AMQPConnectionException If the connection to the broker was lost.

@return boolean
Purge the contents of a queue .