aidlab/aida_back
7
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

TASK:生产消费暂时关闭;

Browse Source
This commit is contained in:
shahaibo
2024-07-09 11:44:18 +08:00
parent a6f02bf22f
commit 2ed63cafd0
2 changed files with 71 additions and 71 deletions
Download Patch File Download Diff File Expand all files Collapse all files

118
src/main/java/com/ai/da/common/RabbitMQ/GenerateConsumer.java
View File

@@ -154,63 +154,63 @@ public class GenerateConsumer {
} }
@RabbitListener(queues = MQConfig.GENERATE_QUEUE) // @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
@RabbitHandler // @RabbitHandler
public void generateConsumer1(Message msg, Channel channel) { // public void generateConsumer1(Message msg, Channel channel) {
generate(msg, channel, "consumer 1"); // generate(msg, channel, "consumer 1");
} // }
//
@RabbitListener(queues = MQConfig.GENERATE_QUEUE) // @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
@RabbitHandler // @RabbitHandler
public void generateConsumer2(Message msg, Channel channel) { // public void generateConsumer2(Message msg, Channel channel) {
generate(msg, channel, "consumer 2"); // generate(msg, channel, "consumer 2");
} // }
//
@RabbitListener(queues = MQConfig.GENERATE_QUEUE) // @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
@RabbitHandler // @RabbitHandler
public void generateConsumer3(Message msg, Channel channel) { // public void generateConsumer3(Message msg, Channel channel) {
generate(msg, channel, "consumer 3"); // generate(msg, channel, "consumer 3");
} // }
//
@RabbitListener(queues = MQConfig.GENERATE_QUEUE) // @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
@RabbitHandler // @RabbitHandler
public void generateConsumer4(Message msg, Channel channel) { // public void generateConsumer4(Message msg, Channel channel) {
generate(msg, channel, "consumer 4"); // generate(msg, channel, "consumer 4");
} // }
//
@RabbitListener(queues = MQConfig.GENERATE_QUEUE) // @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
@RabbitHandler // @RabbitHandler
public void generateConsumer5(Message msg, Channel channel) { // public void generateConsumer5(Message msg, Channel channel) {
generate(msg, channel, "consumer 5"); // generate(msg, channel, "consumer 5");
} // }
//
@RabbitListener(queues = MQConfig.GENERATE_QUEUE) // @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
@RabbitHandler // @RabbitHandler
public void generateConsumer6(Message msg, Channel channel) { // public void generateConsumer6(Message msg, Channel channel) {
generate(msg, channel, "consumer 6"); // generate(msg, channel, "consumer 6");
} // }
//
@RabbitListener(queues = MQConfig.GENERATE_QUEUE) // @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
@RabbitHandler // @RabbitHandler
public void generateConsumer7(Message msg, Channel channel) { // public void generateConsumer7(Message msg, Channel channel) {
generate(msg, channel, "consumer 7"); // generate(msg, channel, "consumer 7");
} // }
//
@RabbitListener(queues = MQConfig.GENERATE_QUEUE) // @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
@RabbitHandler // @RabbitHandler
public void generateConsumer8(Message msg, Channel channel) { // public void generateConsumer8(Message msg, Channel channel) {
generate(msg, channel, "consumer 8"); // generate(msg, channel, "consumer 8");
} // }
//
@RabbitListener(queues = MQConfig.GENERATE_QUEUE) // @RabbitListener(queues = MQConfig.GENERATE_QUEUE)
@RabbitHandler // @RabbitHandler
public void generateConsumer9(Message msg, Channel channel) { // public void generateConsumer9(Message msg, Channel channel) {
generate(msg, channel, "consumer 9"); // generate(msg, channel, "consumer 9");
} // }
//
@RabbitListener(queues = MQConfig.GENERATE_RESULT_QUEUE) // @RabbitListener(queues = MQConfig.GENERATE_RESULT_QUEUE)
@RabbitHandler // @RabbitHandler
public void getGenerateResult(Message msg, Channel channel) { // public void getGenerateResult(Message msg, Channel channel) {
processGenerateResult(msg, channel); // processGenerateResult(msg, channel);
} // }
} }

24
src/main/java/com/ai/da/common/RabbitMQ/SRConsumer.java
View File

@@ -218,17 +218,17 @@ public class SRConsumer {
taskListService.updateTaskStatusOrOutputRedis(uniqueId, "fail", null); taskListService.updateTaskStatusOrOutputRedis(uniqueId, "fail", null);
} }
@RabbitListener(queues = MQConfig.SR_QUEUE) // @RabbitListener(queues = MQConfig.SR_QUEUE)
@RabbitHandler // @RabbitHandler
public void SRConsumer1(Message msg, Channel channel) { // public void SRConsumer1(Message msg, Channel channel) {
superResolution(msg, channel, "consumer 1"); // superResolution(msg, channel, "consumer 1");
} // }
//
//
@RabbitListener(queues = MQConfig.SR_RESULT_QUEUE) // @RabbitListener(queues = MQConfig.SR_RESULT_QUEUE)
@RabbitHandler // @RabbitHandler
public void SRResultConsumer1(Message msg, Channel channel) { // public void SRResultConsumer1(Message msg, Channel channel) {
getSRResult(msg, channel, "consumer 1"); // getSRResult(msg, channel, "consumer 1");
} // }
} }