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 cc679eff..b3aee7cd 100644 --- a/src/main/java/com/ai/da/common/RabbitMQ/GenerateConsumer.java +++ b/src/main/java/com/ai/da/common/RabbitMQ/GenerateConsumer.java @@ -318,15 +318,15 @@ public class GenerateConsumer { 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.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); + } }