<?php
|
/**
|
* 通用 触发器接口
|
*
|
* @author dogstar <chanzonghuang@gmail.com> 20150520
|
*/
|
|
class Task_Progress_Trigger_Common implements Task_Progress_Trigger {
|
|
public function fire($params) {
|
$paramsArr = explode('&', $params);
|
|
$service = !empty($paramsArr[0]) ? trim($paramsArr[0]) : '';
|
$mqClass = !empty($paramsArr[1]) ? trim($paramsArr[1]) : 'Task_MQ_Redis';
|
$runnerClass = !empty($paramsArr[2]) ? trim($paramsArr[2]) : 'Task_Runner_Local';
|
|
$mq = new $mqClass();
|
$runner = new $runnerClass($mq);
|
|
return $runner->go($service);
|
}
|
}
|
