public function sendToWorkerHandler(MessageInterface $msg)
    {
        if (!$this->isWorkerHandlerReady()) {
            $this->getLogger()->debug('WorkerHandler socket not ready to send.');

            return;
        }

        $this->workerHandlerReady = false;
        $this->workerHandlerStream->send($msg);
    }
public function sendToWorkerHandler(MessageInterface $msg)
    {
        if (!$this->isWorkerHandlerReady()) {
            $this->getLogger()->debug('WorkerHandler socket not ready to send.');

            return;
        }

        $this->workerHandlerReady = false;
        $this->workerHandlerStream->send($msg);
    }
public function sendToWorkerHandler ( MessageInterface $ msg ) { if ( ! $ this -> isWorkerHandlerReady ( ) ) { $ this -> getLogger ( ) -> debug ( 'WorkerHandler socket not ready to send.' ) ; return ; } $ this -> workerHandlerReady = false ; $ this -> workerHandlerStream -> send ( $ msg ) ; }
Send the given Message to the Worker Handler.

@param MessageInterface $msg
Send the given Message to the Worker Handler .