task:开启消息监听

2026-06-10 17:38:26 +08:00
parent fe9cc99701
commit d9c0e67c07
1 changed files with 77 additions and 77 deletions
--- a/src/main/java/com/ai/da/common/RabbitMQ/GenerateConsumer.java
+++ b/src/main/java/com/ai/da/common/RabbitMQ/GenerateConsumer.java
@@ -559,83 +559,83 @@ public class GenerateConsumer {
        log.info("============ProcessPoseTransformResult End listening==========");
    }

-//    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
-//    @RabbitHandler
-//    public void generateConsumer1(Message msg, Channel channel) {
-//        generate(msg, channel, "consumer 1");
-//    }
-//
-//    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
-//    @RabbitHandler
-//    public void generateConsumer2(Message msg, Channel channel) {
-//        generate(msg, channel, "consumer 2");
-//    }
-//
-//    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
-//    @RabbitHandler
-//    public void generateConsumer3(Message msg, Channel channel) {
-//        generate(msg, channel, "consumer 3");
-//    }
-//
-//    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
-//    @RabbitHandler
-//    public void generateConsumer4(Message msg, Channel channel) {
-//        generate(msg, channel, "consumer 4");
-//    }
-//
-//    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
-//    @RabbitHandler
-//    public void generateConsumer5(Message msg, Channel channel) {
-//        generate(msg, channel, "consumer 5");
-//    }
-//
-//    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
-//    @RabbitHandler
-//    public void generateConsumer6(Message msg, Channel channel) {
-//        generate(msg, channel, "consumer 6");
-//    }
-//
-//    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
-//    @RabbitHandler
-//    public void generateConsumer7(Message msg, Channel channel) {
-//        generate(msg, channel, "consumer 7");
-//    }
-//
-//    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
-//    @RabbitHandler
-//    public void generateConsumer8(Message msg, Channel channel) {
-//        generate(msg, channel, "consumer 8");
-//    }
-//
-//    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
-//    @RabbitHandler
-//    public void generateConsumer9(Message msg, Channel channel) {
-//        generate(msg, channel, "consumer 9");
-//    }
-//
-//    @RabbitListener(queues = "#{rabbitMQProperties.queues.generateResult}")
-//    @RabbitHandler
-//    public void getGenerateResult(Message msg, Channel channel) {
-//        processGenerateResult(msg, channel);
-//    }
-//
-//    @RabbitListener(queues = "#{rabbitMQProperties.queues.toProductImageResult}")
-//    @RabbitHandler
-//    public void getToProductImageResult(Message msg, Channel channel) {
-//        processToProductImageResult(msg, channel);
-//    }
-//
-//    @RabbitListener(queues = "#{rabbitMQProperties.queues.relightResult}")
-//    @RabbitHandler
-//    public void getRelightResult(Message msg, Channel channel) {
-//        processRelightResult(msg, channel);
-//    }
-//
-//    @RabbitListener(queues = "#{rabbitMQProperties.queues.poseTransform}")
-//    @RabbitHandler
-//    public void getPoseTransformationResult(Message msg, Channel channel) {
-//        processPoseTransformResult(msg, channel);
-//    }
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
+    @RabbitHandler
+    public void generateConsumer1(Message msg, Channel channel) {
+        generate(msg, channel, "consumer 1");
+    }
+
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
+    @RabbitHandler
+    public void generateConsumer2(Message msg, Channel channel) {
+        generate(msg, channel, "consumer 2");
+    }
+
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
+    @RabbitHandler
+    public void generateConsumer3(Message msg, Channel channel) {
+        generate(msg, channel, "consumer 3");
+    }
+
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
+    @RabbitHandler
+    public void generateConsumer4(Message msg, Channel channel) {
+        generate(msg, channel, "consumer 4");
+    }
+
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
+    @RabbitHandler
+    public void generateConsumer5(Message msg, Channel channel) {
+        generate(msg, channel, "consumer 5");
+    }
+
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
+    @RabbitHandler
+    public void generateConsumer6(Message msg, Channel channel) {
+        generate(msg, channel, "consumer 6");
+    }
+
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
+    @RabbitHandler
+    public void generateConsumer7(Message msg, Channel channel) {
+        generate(msg, channel, "consumer 7");
+    }
+
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
+    @RabbitHandler
+    public void generateConsumer8(Message msg, Channel channel) {
+        generate(msg, channel, "consumer 8");
+    }
+
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.generate}")
+    @RabbitHandler
+    public void generateConsumer9(Message msg, Channel channel) {
+        generate(msg, channel, "consumer 9");
+    }
+
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.generateResult}")
+    @RabbitHandler
+    public void getGenerateResult(Message msg, Channel channel) {
+        processGenerateResult(msg, channel);
+    }
+
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.toProductImageResult}")
+    @RabbitHandler
+    public void getToProductImageResult(Message msg, Channel channel) {
+        processToProductImageResult(msg, channel);
+    }
+
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.relightResult}")
+    @RabbitHandler
+    public void getRelightResult(Message msg, Channel channel) {
+        processRelightResult(msg, channel);
+    }
+
+    @RabbitListener(queues = "#{rabbitMQProperties.queues.poseTransform}")
+    @RabbitHandler
+    public void getPoseTransformationResult(Message msg, Channel channel) {
+        processPoseTransformResult(msg, channel);
+    }
 //    @RabbitListener(queues = "#{rabbitMQProperties.queues.designBatch}")
 //    @RabbitHandler
 //    public void getDesignBatchResult(Message msg, Channel channel) {