Kaynağa Gözat

Update RabbitMQConsumer.java

haha 3 yıl önce
ebeveyn
işleme
bce61987a2

+ 1 - 1
seec-oj-server/src/main/java/cn/seecoder/ojserver/rabbitmq/RabbitMQConsumer.java

@@ -30,7 +30,7 @@ public class RabbitMQConsumer {
     }
 
     @RabbitHandler
-    @RabbitListener(queuesToDeclare = @Queue("notice_queue"),concurrency = "10")
+    @RabbitListener(queuesToDeclare = @Queue("notice_queue"),concurrency = "20")
     public void process(CodeJudgeDTO codeJudgeDTO) {
         JudgeResult judgeResult = judgeService.judgeCode(codeJudgeDTO.getProblemId(), codeJudgeDTO.getCodeJudgeVO());
         CodeJudgeResultType message = CodeJudgeResultType.values()[JudgeResultType.ACCEPT.ordinal()];