浏览代码

add offline queue

xiewj 4 月之前
父节点
当前提交
2b1c9a4f2f
共有 1 个文件被更改,包括 6 次插入0 次删除
  1. 6 0
      720yun_fd_consumer/src/main/java/com/gis/listener/container/RabbitMQConfig.java

+ 6 - 0
720yun_fd_consumer/src/main/java/com/gis/listener/container/RabbitMQConfig.java

@@ -76,6 +76,12 @@ public class RabbitMQConfig {
     public Queue sceneWorkQueue() {
         return new Queue(queueNameService.getQueueName(), true, false, false);
     }
+    @Bean
+    public Queue workOfflineQueue() {
+        return new Queue(workOffline, true, false, false);
+    }
+
+
 
     @Bean
     public SimpleMessageListenerContainer doSliceQueueContainer(ConnectionFactory connectionFactory) {