弹性伸缩服务改造1

720yun_fd_consumer/gis_consumer/src/main/java/com/gis/listener/container/RabbitMQConfig.java

@@ -128,7 +128,7 @@ public class RabbitMQConfig {
         log.info("sceneWorkQueue 启动,监听队列-{},动态伸缩启动-{}", queueName, isDynamic);
         container.setQueueNames(queueName);
         container.setMessageListener(sceneWorkQueueListener);
-        container.setAutoStartup(isDynamic); // 根据配置决定是否自动启动
+        container.setAutoStartup(true); // 根据配置决定是否自动启动
         container.setPrefetchCount(2);
         container.setAcknowledgeMode(AcknowledgeMode.MANUAL);
         return container;

720yun_fd_consumer/gis_consumer/src/main/java/com/gis/receiver/QueueNameService.java

@@ -21,9 +21,14 @@ public class QueueNameService  {
     String queue ;
     @Autowired
     IMqEcsService mqEcsService;
-
+    @Value("${mq.listener.dynamic}")
+    private boolean isDynamic;
     public String getQueueName(){
         String queueName = queue;
+        if (!isDynamic){
+            log.info("不是弹性服务,应该获取默认队列去启动,监听队列名为：{}",queueName);
+            return queue;
+        }
         if(StrUtil.isBlank(SysConstants.hostName)){
             log.info("获取hostName失败,监听队列名为：{}",queueName);
             return queueName;