From 15ebd9d41f86506534fdff3a306c45077d955ea1 Mon Sep 17 00:00:00 2001 From: ligang Date: Fri, 12 Apr 2019 11:32:22 +0800 Subject: [PATCH] update verifyQueue --- .../java/cn/escheduler/api/service/QueueService.java | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/escheduler-api/src/main/java/cn/escheduler/api/service/QueueService.java b/escheduler-api/src/main/java/cn/escheduler/api/service/QueueService.java index 24bd6cfc97..45f574ed49 100644 --- a/escheduler-api/src/main/java/cn/escheduler/api/service/QueueService.java +++ b/escheduler-api/src/main/java/cn/escheduler/api/service/QueueService.java @@ -215,11 +215,7 @@ public class QueueService extends BaseService { putMsg(result, Status.REQUEST_PARAMS_NOT_VALID_ERROR, queueName); return result; } - if(checkQueueExist(queue)){ - logger.error("queue value {} has exist, can't create again.", queue); - putMsg(result, Status.QUEUE_VALUE_EXIST, queue); - return result; - } + if(checkQueueNameExist(queueName)){ logger.error("queue name {} has exist, can't create again.", queueName); @@ -227,6 +223,12 @@ public class QueueService extends BaseService { return result; } + if(checkQueueExist(queue)){ + logger.error("queue value {} has exist, can't create again.", queue); + putMsg(result, Status.QUEUE_VALUE_EXIST, queue); + return result; + } + putMsg(result, Status.SUCCESS); return result; }