[FIX] 히스토리 내역 저장 후 sqs발송 로직 수정

lotteon2 · Jan 21, 2024 · f99cbe0 · f99cbe0
1 parent 959ae42
commit f99cbe0
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/main/java/com/dailyon/auctionservice/service/BidService.java b/src/main/java/com/dailyon/auctionservice/service/BidService.java
@@ -77,10 +77,10 @@ private Mono<Void> processAuction(Auction auction, Long bid) {
     Mono<ReadAuctionDetailResponse.ReadProductDetailResponse> productInfo =
         productClient.readProductDetail(auction.getAuctionProductId());
 
-    return Mono.when(
-        saveSuccessfulBiddersHistory(productInfo, auction, bid),
-        saveRemainBiddersHistory(productInfo, auction, bid),
-        sendSqsNotification(auction));
+    return Mono.zip(
+            saveSuccessfulBiddersHistory(productInfo, auction, bid),
+            saveRemainBiddersHistory(productInfo, auction, bid))
+        .then(sendSqsNotification(auction));
   }
 
   private Mono<Void> saveSuccessfulBiddersHistory(