public function pushActionResultInfo(ActionResultingPushDto $resultingPushDto)
    {
        $this->subscriberSocket->setSockOpt(\ZMQ::SOCKOPT_UNSUBSCRIBE, "");

        $this->performerEarlyTerminated->setStandOnSubscription(false);

        $this->logger->debug("Performer was unsubscribed.");

        $this->initOrCheckPushConnection();

        $this->pushSocket->send(serialize($resultingPushDto));

        $this->logger->debug("Performer send actionResulting msg.");

        return null;
    }
public function pushActionResultInfo(ActionResultingPushDto $resultingPushDto)
    {
        $this->subscriberSocket->setSockOpt(\ZMQ::SOCKOPT_UNSUBSCRIBE, "");

        $this->performerEarlyTerminated->setStandOnSubscription(false);

        $this->logger->debug("Performer was unsubscribed.");

        $this->initOrCheckPushConnection();

        $this->pushSocket->send(serialize($resultingPushDto));

        $this->logger->debug("Performer send actionResulting msg.");

        return null;
    }
public function pushActionResultInfo ( ActionResultingPushDto $ resultingPushDto ) { $ this -> subscriberSocket -> setSockOpt ( \ ZMQ :: SOCKOPT_UNSUBSCRIBE , "" ) ; $ this -> performerEarlyTerminated -> setStandOnSubscription ( false ) ; $ this -> logger -> debug ( "Performer was unsubscribed." ) ; $ this -> initOrCheckPushConnection ( ) ; $ this -> pushSocket -> send ( serialize ( $ resultingPushDto ) ) ; $ this -> logger -> debug ( "Performer send actionResulting msg." ) ; return null ; }
After action done worker-subscriber stop subscription and by push socket send action's info
@param ActionResultingPushDto $resultingPushDto
@return null
After action done worker - subscriber stop subscription and by push socket send action s info