public function getCurrentMessageCount()
    {
        // Save the current queue flags and setup the queue in passive mode
        $flags = $this->queue->getFlags();
        $this->queue->setFlags($flags | AMQP_PASSIVE);

        // Declare the queue again as passive to get the count of messages
        $messagesCount = $this->queue->declareQueue();

        // Restore the queue flags
        $this->queue->setFlags($flags);

        return $messagesCount;
    }
public function getCurrentMessageCount()
    {
        // Save the current queue flags and setup the queue in passive mode
        $flags = $this->queue->getFlags();
        $this->queue->setFlags($flags | AMQP_PASSIVE);

        // Declare the queue again as passive to get the count of messages
        $messagesCount = $this->queue->declareQueue();

        // Restore the queue flags
        $this->queue->setFlags($flags);

        return $messagesCount;
    }
public function getCurrentMessageCount ( ) { // Save the current queue flags and setup the queue in passive mode $ flags = $ this -> queue -> getFlags ( ) ; $ this -> queue -> setFlags ( $ flags | AMQP_PASSIVE ) ; // Declare the queue again as passive to get the count of messages $ messagesCount = $ this -> queue -> declareQueue ( ) ; // Restore the queue flags $ this -> queue -> setFlags ( $ flags ) ; return $ messagesCount ; }
Get the current message count.

@return int
Get the current message count .