public function start()
    {
        try {
            $this->createClientSocket();
            $this->createWorkerJobSocket();
            $this->createWorkerReplySocket();
            $this->startWorkerPools();
            $this->loop->addPeriodicTimer(5, [$this, 'monitorChildProcesses']);
            $this->loop->addPeriodicTimer(10, [$this, 'monitorQueue']);
            $this->loop->run();
        } catch (ServerException $e) {
            $errorMsgPattern = 'Server error: %s (%s:%d)';
            $this->logger->emergency(sprintf($errorMsgPattern, $e->getMessage(), $e->getFile(), $e->getLine()));
        }
    }
public function start()
    {
        try {
            $this->createClientSocket();
            $this->createWorkerJobSocket();
            $this->createWorkerReplySocket();
            $this->startWorkerPools();
            $this->loop->addPeriodicTimer(5, [$this, 'monitorChildProcesses']);
            $this->loop->addPeriodicTimer(10, [$this, 'monitorQueue']);
            $this->loop->run();
        } catch (ServerException $e) {
            $errorMsgPattern = 'Server error: %s (%s:%d)';
            $this->logger->emergency(sprintf($errorMsgPattern, $e->getMessage(), $e->getFile(), $e->getLine()));
        }
    }
public function start ( ) { try { $ this -> createClientSocket ( ) ; $ this -> createWorkerJobSocket ( ) ; $ this -> createWorkerReplySocket ( ) ; $ this -> startWorkerPools ( ) ; $ this -> loop -> addPeriodicTimer ( 5 , [ $ this , 'monitorChildProcesses' ] ) ; $ this -> loop -> addPeriodicTimer ( 10 , [ $ this , 'monitorQueue' ] ) ; $ this -> loop -> run ( ) ; } catch ( ServerException $ e ) { $ errorMsgPattern = 'Server error: %s (%s:%d)' ; $ this -> logger -> emergency ( sprintf ( $ errorMsgPattern , $ e -> getMessage ( ) , $ e -> getFile ( ) , $ e -> getLine ( ) ) ) ; } }
Creates sockets and fires up worker processes.
Creates sockets and fires up worker processes .