弹性伸缩服务改造

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

@@ -44,6 +44,8 @@ public class RabbitMQConfig {
     DoSliceQueueListener doSliceQueueListener;
     @Autowired
     PanoPayStatusSceneQueueListener panoPayStatusSceneQueueListener;
+    @Autowired
+    SceneQueueListener sceneQueueListener;
 
 
     @Bean
@@ -112,7 +114,7 @@ public class RabbitMQConfig {
         SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory);
         log.info("sceneQueue 启动,监听队列-{},动态伸缩启动-{}", sceneQueue, !isDynamic);
         container.setQueueNames(sceneQueue);
-        container.setMessageListener(new SceneQueueListener());
+        container.setMessageListener(sceneQueueListener);
         container.setAutoStartup(!isDynamic); // 根据配置决定是否自动启动
         container.setPrefetchCount(1);
         container.setAcknowledgeMode(AcknowledgeMode.MANUAL);