Browse Source

update verifyQueue

ligang 6 years ago
parent
commit
15ebd9d41f

+ 7 - 5
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);
             putMsg(result, Status.REQUEST_PARAMS_NOT_VALID_ERROR, queueName);
             return result;
             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)){
         if(checkQueueNameExist(queueName)){
             logger.error("queue name {} has exist, can't create again.", queueName);
             logger.error("queue name {} has exist, can't create again.", queueName);
@@ -227,6 +223,12 @@ public class QueueService extends BaseService {
             return result;
             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);
         putMsg(result, Status.SUCCESS);
         return result;
         return result;
     }
     }