Merge pull request #49 from lotteon2/develop

[FIX] start 펍섭 수정
lotteon2 · Jan 21, 2024 · 994d76e · 994d76e
2 parents 22d2daf + c47215f
commit 994d76e
Showing 1 changed file with 4 additions and 3 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
@@ -51,13 +51,14 @@ public Mono<Void> subscribeStartTrigger() {
         .listenTo(new PatternTopic(START_TOPIC))
         .map(ReactiveSubscription.Message::getMessage)
         .flatMap(payload -> objectStringConverter.stringToObject(payload, ChatPayload.class))
-        .handle(
-            (chatPayload, sink) -> {
+        .flatMap(
+            chatPayload -> {
               Object data = chatPayload.getData();
               if (data instanceof String) {
                 scheduler.startJob((String) data);
-                sink.next(data);
               }
+              return chatWebSocketHandler.sendMessage(
+                  chatPayload); // send message and return its Mono
             })
         .then();
   }