Alawn/udf
1
0
Fork 0
mirror of https://gitee.com/wangkang/udf.git synced 2026-11-01 06:30:06 +00:00
Code Issues Releases Wiki Activity

调整代码

Browse Source
This commit is contained in:
wangkang
2018-04-12 14:52:08 +08:00
parent 73319f4686
commit 63e38e57fb
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
udf-starter/udf-starter-scheduler/src/main/java/org/itkk/udf/scheduler/web/SchClientCallbackController.java
+2 -2
View File
@@ -37,14 +37,14 @@ public class SchClientCallbackController implements ISchClientCallbackController
@Override
public RestResponse<String> callback(@RequestBody RmsJobResult result) {
//获得key
String name = AbstractBaseRmsJob.RMS_JOB_DISALLOW_CONCURRENT_PREFIX + result.getParam().getServiceCode() + "_" + result.getParam().getBeanName();
try {
if (rmsJobLog != null) {
rmsJobLog.save(null, result);
}
return new RestResponse<>();
} finally {
//获得key
String name = AbstractBaseRmsJob.RMS_JOB_DISALLOW_CONCURRENT_PREFIX + result.getParam().getServiceCode() + "_" + result.getParam().getBeanName();
//解锁
redisBasedDistributedLock.unlock(name);
}