Bladeren bron

修改队列名称

lixing 2 jaren geleden
bovenliggende
commit
6dda377aef
1 gewijzigde bestanden met toevoegingen van 1 en 1 verwijderingen
  1. 1 1
      src/main/java/com/persagy/service/impl/AlarmHandleServiceImpl.java

+ 1 - 1
src/main/java/com/persagy/service/impl/AlarmHandleServiceImpl.java

@@ -101,7 +101,7 @@ public class AlarmHandleServiceImpl {
      * @version: V1.0
      */
     @RabbitHandler
-    @RabbitListener(queues = "alarm-data-queue")
+    @RabbitListener(queues = "${group.code}-" + "alarm-data-queue")
     @SneakyThrows
     public void handleIotMsg(Message message, Channel channel) {
         try {