feature: remove unused query

telekom · Apr 18, 2024 · 72c5200 · 72c5200
1 parent 9ac6f6f
commit 72c5200
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
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
@@ -32,8 +32,6 @@ public interface MessageStateMongoRepo extends MongoRepository<MessageStateMongo
     Slice<MessageStateMongoDocument> findByDeliveryTypeAndStatusAndModifiedLessThanEqual(DeliveryType deliveryType, Status status, Date upperTimestampThreshold);
     Slice<MessageStateMongoDocument> findByDeliveryTypeAndStatusAndModifiedLessThanEqual(DeliveryType deliveryType, Status status, Date upperTimestampThreshold, Pageable pageable);
 
-    Slice<MessageStateMongoDocument> findByStatusAndSubscriptionIdsAndTimestampLessThanEqual(Status status, List<String> subscriptionIds, Date upperTimestampThreshold, Pageable pageable);
-
     @Query(value = "{ \"error.type\": \"de.telekom.horizon.dude.exception.CallbackUrlNotFoundException\" , \"status\": { \"$eq\": \"FAILED\" } }", sort = "{timestamp: 1}")
     Slice<MessageStateMongoDocument> findStatusFailedWithCallbackExceptionAsc();
     @Query(value = "{ \"error.type\": \"de.telekom.horizon.dude.exception.CallbackUrlNotFoundException\" , \"status\": { \"$eq\": \"FAILED\" } }", sort = "{timestamp: 1}")
@@ -58,6 +56,8 @@ public interface MessageStateMongoRepo extends MongoRepository<MessageStateMongo
     @Query(value = "{$or:[{\"error.type\":{ $exists: false}},{\"error.type\":\"de.telekom.horizon.dude.exception.CallbackUrlNotFoundException\"}], status:{ $in: ?0 }, subscriptionId:{ $in: ?1 }, modified: { $lte: ?2 } }", sort = "{timestamp: 1}")
     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);
 
     List<MessageStateMongoDocument> findByMultiplexedFrom(String multiplexedFromId);
 

diff --git a/...ore/src/test/java/de/telekom/eni/pandora/horizon/mongo/MessageStateMongoDocumentTest.java b/...ore/src/test/java/de/telekom/eni/pandora/horizon/mongo/MessageStateMongoDocumentTest.java
@@ -67,7 +67,7 @@ static void setProperties(DynamicPropertyRegistry registry) {
 
     @BeforeAll
     static void initContainer() {
-//        mongoDBContainer.start();
+        //mongoDBContainer.start();
 
         testPartition = 123;
         testDeliveryType = DeliveryType.CALLBACK;