1111

src/main/java/com/fdkankan/jp/xspace/listener/RabbitMqListener.java

@@ -60,10 +60,10 @@ public class RabbitMqListener {
      * queuesToDeclare = @Queue("${queue.modeling.modeling-test}"),  如果队列不不存在会自动创建队列
      * concurrency = "3"    设置消费线程数，每个线程每次只拉取一条消息消费
      */
-    @RabbitListener(
-        queuesToDeclare = @Queue(RabbitmqConstant.QUEUE_PACK_XSPACE),
-        concurrency = "1"
-    )
+//    @RabbitListener(
+//        queuesToDeclare = @Queue(RabbitmqConstant.QUEUE_PACK_XSPACE),
+//        concurrency = "1"
+//    )
     public void packXspace(Channel channel, Message message) throws Exception {
         String messageId = message.getMessageProperties().getMessageId();
         String msg = new String(message.getBody(), StandardCharsets.UTF_8);