[FIX] log

lotteon2 · Jan 26, 2024 · c9e2b30 · c9e2b30
1 parent 4886399
commit c9e2b30
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 6 deletions.
diff --git a/src/main/java/com/dailyon/auctionservice/chat/messaging/RedisChatMessageListener.java b/src/main/java/com/dailyon/auctionservice/chat/messaging/RedisChatMessageListener.java
@@ -54,9 +54,7 @@ public Mono<Void> subscribeStartTrigger() {
         .flatMap(
             chatPayload -> {
               Object data = chatPayload.getData();
-              if (data instanceof String) {
-                scheduler.startJob((String) data);
-              }
+              scheduler.startJob((String) data);
               return chatWebSocketHandler.sendMessage(
                   chatPayload); // send message and return its Mono
             })

diff --git a/src/main/java/com/dailyon/auctionservice/chat/messaging/RedisChatMessagePublisher.java b/src/main/java/com/dailyon/auctionservice/chat/messaging/RedisChatMessagePublisher.java
@@ -42,6 +42,7 @@ public void init() {
   }
 
   public Mono<Long> publishChatMessage(String message) {
+    log.info("여기 publishChatMessage {}", message);
     return Mono.just(hostName)
         .map(
             host -> {
@@ -57,7 +58,9 @@ public Mono<Long> publishChatMessage(String message) {
             result -> {
               try {
                 ChatPayload chatPayload = objectMapper.readValue(result, ChatPayload.class);
+                log.info("여기 push쪽 command : {}", chatPayload.getCommand());
                 if (chatPayload.getCommand().equals(ChatCommand.START)) {
+                  log.info("들어옴");
                   return reactiveStringRedisTemplate
                       .convertAndSend(START_TOPIC, result)
                       .doOnSuccess(

diff --git a/src/main/java/com/dailyon/auctionservice/controller/ChatHandler.java b/src/main/java/com/dailyon/auctionservice/controller/ChatHandler.java
@@ -70,8 +70,7 @@ public Mono<Sinks.EmitResult> sendMessage(ChatPayload chatMessage) {
     return Mono.fromSupplier(() -> chatMessageSink.tryEmitNext(chatMessage))
         .doOnSuccess(
             emitResult -> {
-              if (emitResult.isFailure()) {
-              }
+              if (emitResult.isFailure()) {}
             });
   }
 
@@ -90,7 +89,6 @@ public Mono<Void> broadCast(ChatPayload chatPayload) {
   }
 
   public Mono<Void> broadCastStart(ChatPayload payload) {
-    log.info("start payload : {}", payload.getData());
     return objectStringConverter
         .objectToString(payload)
         .flatMap(redisChatMessagePublisher::publishChatMessage)