启动mq消费者之前检测是否挂上nas

src/main/java/com/fdkankan/modeling/receiver/QueueNameService.java

@@ -1,5 +1,6 @@
 package com.fdkankan.modeling.receiver;
 
+import cn.hutool.core.io.FileUtil;
 import com.fdkankan.modeling.constants.SysConstants;
 import com.fdkankan.modeling.entity.MqEcs;
 import com.fdkankan.modeling.service.IMqEcsService;
@@ -20,6 +21,10 @@ public class QueueNameService {
 
 
     public String getQueueName(){
+        String checkFilePath = "/mnt/dont_delete/nas_check.txt";
+        if(!FileUtil.exist(checkFilePath)){
+            return "modeling-no-nas";
+        }
         String queueName = queue;
         if(StringUtils.isBlank(SysConstants.hostName)){
             log.info("获取hostName失败,监听队列名为：{}",queueName);