feature: Add status list as data type for the new mongo query for Pol…

…aris
telekom · Apr 18, 2024 · bdd6f14 · bdd6f14
1 parent 72c5200
commit bdd6f14
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/.../src/main/java/de/telekom/eni/pandora/horizon/mongo/repository/MessageStateMongoRepo.java b/.../src/main/java/de/telekom/eni/pandora/horizon/mongo/repository/MessageStateMongoRepo.java
@@ -57,7 +57,7 @@ public interface MessageStateMongoRepo extends MongoRepository<MessageStateMongo
     Slice<MessageStateMongoDocument> findByStatusInPlusCallbackUrlNotFoundExceptionAsc(List<Status> status, List<String> subscriptionIds, Date timestampOlderThan, Pageable pageable);
 
     @Query(value = "{$or:[{\"status\":{ $eq: \"WAITING\"}},{\"error.type\":\"de.telekom.horizon.dude.exception.CallbackUrlNotFoundException\"}], status:{ $in: ?0 }, subscriptionId:{ $in: ?1 }, modified: { $lte: ?2 }}", sort = "{timestamp: 1}")
-    Slice<MessageStateMongoDocument> findByWaitingOrFailedWithCallbackExceptionAndSubscriptionIdsAndTimestampLessThanEqual(Status status, List<String> subscriptionIds, Date upperTimestampThreshold, Pageable pageable);
+    Slice<MessageStateMongoDocument> findByWaitingOrFailedWithCallbackExceptionAndSubscriptionIdsAndTimestampLessThanEqual(List<Status> status, List<String> subscriptionIds, Date upperTimestampThreshold, Pageable pageable);
 
     List<MessageStateMongoDocument> findByMultiplexedFrom(String multiplexedFromId);