public function start()
    {
        $this->createQueue();

        while (count($this->getChannel()->callbacks)) {
            try {
                $this->getChannel()->wait();
            } catch (\Exception $e) {
                fwrite($this->errOutput, $e->getMessage());
                $this->forceReconnect();

                continue;
            }
        }
        $connection = $this->getChannel()->getConnection();
        $this->getChannel()->close();
        $connection->close();
    }
public function start()
    {
        $this->createQueue();

        while (count($this->getChannel()->callbacks)) {
            try {
                $this->getChannel()->wait();
            } catch (\Exception $e) {
                fwrite($this->errOutput, $e->getMessage());
                $this->forceReconnect();

                continue;
            }
        }
        $connection = $this->getChannel()->getConnection();
        $this->getChannel()->close();
        $connection->close();
    }
public function start ( ) { $ this -> createQueue ( ) ; while ( count ( $ this -> getChannel ( ) -> callbacks ) ) { try { $ this -> getChannel ( ) -> wait ( ) ; } catch ( \ Exception $ e ) { fwrite ( $ this -> errOutput , $ e -> getMessage ( ) ) ; $ this -> forceReconnect ( ) ; continue ; } } $ connection = $ this -> getChannel ( ) -> getConnection ( ) ; $ this -> getChannel ( ) -> close ( ) ; $ connection -> close ( ) ; }
Declare and start queue in broker.
Declare and start queue in broker .