fileMq = new PhalApi\Task\MQ\FileMQ(); $this->taskRunner = new Task_Runner_Mock($this->fileMq); } protected function tearDown() { } /** * @group testGo */ public function testGo() { $service = 'Demo.TestGo'; $this->fileMq->add($service, array()); $this->fileMq->add($service, array('id' => 123)); $this->fileMq->add($service, array('id' => 888, 'name' => 'phalapi')); $rs = $this->taskRunner->go($service); //var_dump($rs); $this->assertNotEmpty($rs); $this->assertArrayHasKey('total', $rs); $this->assertArrayHasKey('fail', $rs); $this->assertEquals(3, $rs['total']); $this->assertEquals(0, $rs['fail']); } } class Task_Runner_Mock extends PhalApi\Task\Runner { protected function youGo($service, $params) { echo "Task_Runner_Mock::youGo(", $service , ", ", json_encode($params), ") ... \n"; return true; } }