Parcourir la source

增加消费队列

xiewj il y a 1 an
Parent
commit
b756638647

+ 1 - 1
720yun_fd_consumer/gis_consumer/src/main/java/com/gis/listener/SceneListener.java

@@ -128,7 +128,7 @@ public class SceneListener {
                 channel.basicAck(deliveryTag, false);
             }else if (ObjectUtil.isNotEmpty(param.getSceneCode())&&param.getStatus()==1) {
                 //发送到处理队列
-                rabbitMqProducerUtil.sendByWorkQueue(relicsInitQueue, msg);
+                rabbitMqProducerUtil.sendByWorkQueue(sceneQueueWork, msg);
                 channel.basicAck(deliveryTag, false);
 
             }