From d9c0e67c07163e3fa31252583379b41feea6e0d0 Mon Sep 17 00:00:00 2001 From: xupei Date: Wed, 10 Jun 2026 17:38:26 +0800 Subject: [PATCH] =?UTF-8?q?task:=E5=BC=80=E5=90=AF=E6=B6=88=E6=81=AF?= =?UTF-8?q?=E7=9B=91=E5=90=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../da/common/RabbitMQ/GenerateConsumer.java | 154 +++++++++--------- 1 file changed, 77 insertions(+), 77 deletions(-) diff --git a/src/main/java/com/ai/da/common/RabbitMQ/GenerateConsumer.java b/src/main/java/com/ai/da/common/RabbitMQ/GenerateConsumer.java index 21a08a7d..e26d8c5a 100644 --- 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) {