diff --git a/src/main/java/org/ezcode/codetest/application/submission/service/SubmissionService.java b/src/main/java/org/ezcode/codetest/application/submission/service/SubmissionService.java index cfcacce6..b59d3972 100644 --- a/src/main/java/org/ezcode/codetest/application/submission/service/SubmissionService.java +++ b/src/main/java/org/ezcode/codetest/application/submission/service/SubmissionService.java @@ -1,13 +1,9 @@ package org.ezcode.codetest.application.submission.service; import java.util.List; -import java.util.Map; import java.util.UUID; -import java.util.concurrent.ConcurrentHashMap; import org.ezcode.codetest.application.submission.aop.CodeReviewLock; -import org.ezcode.codetest.application.submission.dto.event.TestcaseListInitializedEvent; -import org.ezcode.codetest.application.submission.dto.event.payload.InitTestcaseListPayload; import org.ezcode.codetest.application.submission.dto.request.review.CodeReviewRequest; import org.ezcode.codetest.application.submission.dto.request.review.ReviewPayload; import org.ezcode.codetest.application.submission.dto.response.review.CodeReviewResponse; @@ -17,7 +13,6 @@ import org.ezcode.codetest.application.submission.port.ExceptionNotifier; import org.ezcode.codetest.application.submission.port.LockManager; import org.ezcode.codetest.application.submission.port.QueueProducer; -import org.ezcode.codetest.domain.problem.model.entity.Testcase; import org.ezcode.codetest.domain.submission.exception.SubmissionException; import org.ezcode.codetest.domain.submission.exception.code.SubmissionExceptionCode; import org.ezcode.codetest.infrastructure.event.dto.submission.SubmissionMessage; @@ -33,7 +28,6 @@ import org.ezcode.codetest.domain.user.model.entity.AuthUser; import org.ezcode.codetest.domain.user.model.entity.User; import org.ezcode.codetest.domain.user.service.UserDomainService; -import org.ezcode.codetest.infrastructure.event.dto.submission.response.InitTestcaseListResponse; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -78,7 +72,6 @@ public void processSubmissionAsync(SubmissionMessage msg) { try { log.info("[Submission RUN] Thread = {}", Thread.currentThread().getName()); log.info("[큐 수신] SubmissionMessage.sessionKey: {}", msg.sessionKey()); - SubmissionContext ctx = createSubmissionContext(msg); judgementService.publishInitTestcases(ctx); judgementService.runTestcases(ctx); diff --git a/src/main/java/org/ezcode/codetest/infrastructure/event/listener/RedisJudgeQueueConsumer.java b/src/main/java/org/ezcode/codetest/infrastructure/event/listener/RedisJudgeQueueConsumer.java index ae98b4f7..15f13518 100644 --- a/src/main/java/org/ezcode/codetest/infrastructure/event/listener/RedisJudgeQueueConsumer.java +++ b/src/main/java/org/ezcode/codetest/infrastructure/event/listener/RedisJudgeQueueConsumer.java @@ -36,6 +36,7 @@ public void onMessage(MapRecord message) { try { log.info("[컨슈머 수신] {}", msg.sessionKey()); + Thread.sleep(6000); submissionService.processSubmissionAsync(msg); log.info("[컨슈머 ACK] messageId={}", message.getId()); diff --git a/src/main/java/org/ezcode/codetest/infrastructure/event/publisher/StompMessageService.java b/src/main/java/org/ezcode/codetest/infrastructure/event/publisher/StompMessageService.java index 3b1f5205..72cb9667 100644 --- a/src/main/java/org/ezcode/codetest/infrastructure/event/publisher/StompMessageService.java +++ b/src/main/java/org/ezcode/codetest/infrastructure/event/publisher/StompMessageService.java @@ -9,17 +9,14 @@ import org.springframework.messaging.simp.SimpMessageType; import java.util.List; -import java.util.Map; -import java.util.Queue; -import java.util.Set; -import java.util.concurrent.ConcurrentHashMap; -import java.util.concurrent.ConcurrentLinkedQueue; import org.springframework.messaging.simp.SimpMessagingTemplate; import org.springframework.stereotype.Component; import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +@Slf4j @Component @RequiredArgsConstructor public class StompMessageService { @@ -65,6 +62,7 @@ public void sendInitTestcases( String principalName, List dataList ) { + log.info("init 발행"); messagingTemplate.convertAndSendToUser( principalName, SUBMISSION_DEST_PREFIX.formatted(sessionKey) + "/init", @@ -77,6 +75,7 @@ public void sendTestcaseResultUpdate( String principalName, JudgeResultResponse data ) { + log.info("case 발행"); messagingTemplate.convertAndSendToUser( principalName, SUBMISSION_DEST_PREFIX.formatted(sessionKey) + "/case", @@ -89,6 +88,7 @@ public void sendFinalResult( String principalName, SubmissionFinalResultResponse data ) { + log.info("final 발행"); messagingTemplate.convertAndSendToUser( principalName, SUBMISSION_DEST_PREFIX.formatted(sessionKey) + "/final",