1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
| <?php
| /**
| * 数据库MQ
| *
| * - 队列存放于数据库表中，并支持分表
| *
| * @author dogstar <chanzonghuang@gmail.com> 20150516
| */
|
| class Task_MQ_DB implements Task_MQ {
|
| public function add($service, $params = array()) {
| $model = new Model_Task_TaskMq();
| return $model->add($service, $params);
| }
|
| public function pop($service, $num = 1) {
| $model = new Model_Task_TaskMq();
| return $model->pop($service, $num);
| }
| }
|
|
