forked from dromara/disjob
/
WorkerServiceProvider.java
36 lines (29 loc) · 1.34 KB
/
WorkerServiceProvider.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
/* __________ _____ *\
** \______ \____ _____/ ____\____ ____ Copyright (c) 2017-2023 Ponfee **
** | ___/ _ \ / \ __\/ __ \_/ __ \ http://www.ponfee.cn **
** | | ( <_> ) | \ | \ ___/\ ___/ Apache License Version 2.0 **
** |____| \____/|___| /__| \___ >\___ > http://www.apache.org/licenses/ **
** \/ \/ \/ **
\* */
package cn.ponfee.scheduler.worker.rpc;
import cn.ponfee.scheduler.common.spring.RpcController;
import cn.ponfee.scheduler.core.base.WorkerService;
import cn.ponfee.scheduler.core.exception.JobException;
import cn.ponfee.scheduler.core.handle.JobHandlerUtils;
import cn.ponfee.scheduler.core.handle.SplitTask;
import java.util.List;
/**
* Worker service provider.
*
* @author Ponfee
*/
public class WorkerServiceProvider implements WorkerService, RpcController {
@Override
public boolean verify(String jobHandler, String jobParam) {
return JobHandlerUtils.verify(jobHandler, jobParam);
}
@Override
public List<SplitTask> split(String jobHandler, String jobParam) throws JobException {
return JobHandlerUtils.split(jobHandler, jobParam);
}
}