<?php
/**
* * * * * * * *<4297088@qq.com>
* */
namespace cn\gz53\framework\dao\websocket;
use cn\gz53\framework\dao\Dao;
use cn\gz53\framework\model\po\websocket\WebSocketServerWorkerCallbackGetPo;
use cn\gz53\framework\model\po\websocket\WebSocketServerWorkerRunnerCallbackSetPo;
use cn\gz53\framework\sdk\worker\WebSocketServerWorkerSdk;
class WebSocketServerWorkerDao extends Dao
{
public function setInitCallback(WebSocketServerWorkerRunnerCallbackSetDaoI $bo){
$po = WebSocketServerWorkerRunnerCallbackSetPo::getInstance($this->_context);
$mqWorkerSdk = WebSocketServerWorkerSdk::getInstance($this->_context);
$po->setRunnerInitCallback($bo->getInitCallback());
if(!$mqWorkerSdk->setRunnerCallback($po)){
return false;
}
return true;
}
public function getWorkerCallback(WebSocketServerWorkerCallbackGetDaoI $bo){
$po = WebSocketServerWorkerCallbackGetPo::getInstance($this->_context);
$mqWorkerSdk = WebSocketServerWorkerSdk::getInstance($this->_context);
if(!$mqWorkerSdk->getWorkerCallback($po)){
return false;
}
$bo->setWorkerStartCallback($po->getWorkerStartCallback());
return true;
}
}