Browse Source

feat: 消费端10concurrency

haha 3 years ago
parent
commit
183a5ef5fd

+ 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"))
+    @RabbitListener(queuesToDeclare = @Queue("notice_queue"),concurrency = "10")
     public void process(CodeJudgeDTO codeJudgeDTO) {
         JudgeResult judgeResult = judgeService.judgeCode(codeJudgeDTO.getProblemId(), codeJudgeDTO.getCodeJudgeVO());
         CodeJudgeResultType message = CodeJudgeResultType.values()[JudgeResultType.ACCEPT.ordinal()];

+ 1 - 1
seec-oj-server/src/main/java/cn/seecoder/ojserver/service/impl/JudgeServiceImpl.java

@@ -113,7 +113,7 @@ public class JudgeServiceImpl implements JudgeService {
         commit.setScore(score);
         commit.setJudgeTime(new Date());
         commitDAO.save(commit);
-        return null;
+        return judgeResult;
     }
 
     @Override