From 63e38e57fbed947683a7385c6599cb17dee16449 Mon Sep 17 00:00:00 2001 From: wangkang Date: Thu, 12 Apr 2018 14:52:08 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../itkk/udf/scheduler/web/SchClientCallbackController.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/udf-starter/udf-starter-scheduler/src/main/java/org/itkk/udf/scheduler/web/SchClientCallbackController.java b/udf-starter/udf-starter-scheduler/src/main/java/org/itkk/udf/scheduler/web/SchClientCallbackController.java index f1c6073..30dc64d 100644 --- a/udf-starter/udf-starter-scheduler/src/main/java/org/itkk/udf/scheduler/web/SchClientCallbackController.java +++ b/udf-starter/udf-starter-scheduler/src/main/java/org/itkk/udf/scheduler/web/SchClientCallbackController.java @@ -37,14 +37,14 @@ public class SchClientCallbackController implements ISchClientCallbackController @Override public RestResponse 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); }