diff --git a/src/main/java/com/manchui/domain/chat/repository/mongodb/ChatMessageRepository.java b/src/main/java/com/manchui/domain/chat/repository/mongodb/ChatMessageRepository.java index e59dfd6..aac8788 100644 --- a/src/main/java/com/manchui/domain/chat/repository/mongodb/ChatMessageRepository.java +++ b/src/main/java/com/manchui/domain/chat/repository/mongodb/ChatMessageRepository.java @@ -13,7 +13,7 @@ public interface ChatMessageRepository extends ReactiveMongoRepository findByRoomIdAndCreatedAtGreaterThanEqualOrderByCreatedAtDesc(String roomId, LocalDateTime createdAt); - @Query(value = "{ 'roomId': ?0, '_id': { $lt: ?1 }, 'createdAt': { $lt: ?2 } }", sort = "{ '_id': -1 }") + @Query(value = "{ 'roomId': ?0, '_id': { $lt: ?1 }, 'createdAt': { $gte: ?2 } }", sort = "{ '_id': -1 }") Flux findByRoomIdAndIdLessThanAndCreatedAtGreaterThanEqualOrderByIdDesc(String roomId, ObjectId lastMessageId, LocalDateTime createdAt); Mono findFirstByRoomIdOrderByCreatedAtDesc(String roomId);