public function sendToService(MessageInterface $msg)
    {
        if (!$this->isServiceStreamReady()) {
            $this->getLogger()->debug('Service socket not ready to send.');

            return;
        }

        $this->getLogger()->debug('Sending to service.');
        $this->serviceStreamReady = false;
        $this->serviceStream->send($msg);
    }
public function sendToService(MessageInterface $msg)
    {
        if (!$this->isServiceStreamReady()) {
            $this->getLogger()->debug('Service socket not ready to send.');

            return;
        }

        $this->getLogger()->debug('Sending to service.');
        $this->serviceStreamReady = false;
        $this->serviceStream->send($msg);
    }
public function sendToService ( MessageInterface $ msg ) { if ( ! $ this -> isServiceStreamReady ( ) ) { $ this -> getLogger ( ) -> debug ( 'Service socket not ready to send.' ) ; return ; } $ this -> getLogger ( ) -> debug ( 'Sending to service.' ) ; $ this -> serviceStreamReady = false ; $ this -> serviceStream -> send ( $ msg ) ; }
Send the given Message to the Service.

@param MessageInterface $msg
Send the given Message to the Service .