diff --git a/src/main/java/com/uci/dao/repository/XMessageRepository.java b/src/main/java/com/uci/dao/repository/XMessageRepository.java index 7584262..65d0866 100644 --- a/src/main/java/com/uci/dao/repository/XMessageRepository.java +++ b/src/main/java/com/uci/dao/repository/XMessageRepository.java @@ -52,6 +52,9 @@ public interface XMessageRepository extends ReactiveCassandraRepository findAllByMessageIdAndUserIdInAndFromIdIn(String messageId, List listUserId, List listFromId); + + @AllowFiltering + Flux findAllByUserId(String userID); }