1
2
3
4
5
6
7
8
9
10
11
12
| // {app_root}/agent.js
| module.exports = function(agent) {
| class CustomStrategy extends agent.ScheduleStrategy {
| start() {
| agent.notify.subscribe("remote_task", data => {
| //随机通知一个 worker 执行任务
| this.sendOne(data);
| });
| }
| }
| agent.schedule.use("custsom", CustomStrategy);
| };
|
|
