Commit c143dfab by huangfusuper

修正NUM字段

parent 74289a20
...@@ -5,6 +5,7 @@ import com.byit.conf.MythJobAutoConfigure; ...@@ -5,6 +5,7 @@ import com.byit.conf.MythJobAutoConfigure;
import com.byit.dto.executor.DispatchResponseDto; import com.byit.dto.executor.DispatchResponseDto;
import com.byit.dto.executor.JobRunResultDto; import com.byit.dto.executor.JobRunResultDto;
import com.byit.dto.executor.PluginBeanJobInfo; import com.byit.dto.executor.PluginBeanJobInfo;
import com.byit.enums.CallMethodEnum;
import com.byit.model.JobTask; import com.byit.model.JobTask;
import com.byit.packet.request.PluginRpcRequestPacket; import com.byit.packet.request.PluginRpcRequestPacket;
import com.byit.packet.response.PluginRpcResponsePacket; import com.byit.packet.response.PluginRpcResponsePacket;
...@@ -39,7 +40,7 @@ public class JobController { ...@@ -39,7 +40,7 @@ public class JobController {
this.jobTaskService = jobTaskService; this.jobTaskService = jobTaskService;
} }
@TaskClient @TaskClient(timeout = 30000, callMethodEnum = CallMethodEnum.SYNCHRONIZE)
private TaskServer taskServer; private TaskServer taskServer;
...@@ -65,6 +66,7 @@ public class JobController { ...@@ -65,6 +66,7 @@ public class JobController {
public PluginRpcResponsePacket test(){ public PluginRpcResponsePacket test(){
PluginRpcRequestPacket rpcRequestPacket = new PluginRpcRequestPacket(); PluginRpcRequestPacket rpcRequestPacket = new PluginRpcRequestPacket();
rpcRequestPacket.setJobName("qualityBeforeTaskJob"); rpcRequestPacket.setJobName("qualityBeforeTaskJob");
rpcRequestPacket.setCallMethodEnum(CallMethodEnum.SYNCHRONIZE);
PluginRpcResponsePacket call = taskServer.call(rpcRequestPacket); PluginRpcResponsePacket call = taskServer.call(rpcRequestPacket);
return call; return call;
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment