XMessage data

samagra-comms · Jun 29, 2022 · 55aee78 · 55aee78
1 parent 8bd995f
commit 55aee78
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/main/java/com/uci/dao/repository/XMessageRepository.java b/src/main/java/com/uci/dao/repository/XMessageRepository.java
@@ -34,7 +34,7 @@ public interface XMessageRepository extends ReactiveCassandraRepository<XMessage
     Flux<XMessageDAO> findFirstByAppOrderByTimestampDesc(String appName);
 
     @AllowFiltering
-    Flux<Slice<XMessageDAO>> findAllByUserId(Pageable pageable, String userID);
+    Flux<XMessageDAO> findAllByUserId(Pageable pageable, String userID);
 
     Flux<XMessageDAO> findByMessageId(String messageID);
 
@@ -72,10 +72,10 @@ public interface XMessageRepository extends ReactiveCassandraRepository<XMessage
     Flux<Slice<XMessageDAO>> findAllByUserIdAndFromId(Pageable paging, String userID, String fromID);
 
     @AllowFiltering
-    Flux<Slice<XMessageDAO>> findAllByAppAndTimestampAfterAndTimestampBeforeAndProvider(Pageable paging, String name, Timestamp startDate, Timestamp endDate, String provider);
+    Mono<Slice<XMessageDAO>> findAllByAppAndTimestampAfterAndTimestampBeforeAndProvider(Pageable paging, String name, Timestamp startDate, Timestamp endDate, String provider);
 
     @AllowFiltering
-    Flux<Slice<XMessageDAO>> findAllByUserIdAndTimestampAfterAndTimestampBeforeAndProvider(Pageable paging, String userId, Timestamp startDate, Timestamp endDate, String provider);
+    Mono<Slice<XMessageDAO>> findAllByUserIdAndTimestampAfterAndTimestampBeforeAndProvider(Pageable paging, String userId, Timestamp startDate, Timestamp endDate, String provider);
 }