fix(sse): fix offset based sse mongo interfaces

telekom · Nov 25, 2024 · d1222c3 · d1222c3
1 parent 6dd5eb2
commit d1222c3
Showing 1 changed file with 2 additions and 2 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
@@ -44,9 +44,9 @@ public interface MessageStateMongoRepo extends MongoRepository<MessageStateMongo
     Slice<MessageStateMongoDocument> findByStatusInAndDeliveryTypeAndSubscriptionIdAsc(List<Status> status, DeliveryType deliveryType, String subscriptionId, Pageable pageable);
 
     @Query(value = "{'_id':  {$gt:  ?0}, deliveryType: ?1}", sort = "{timestamp: 1}")
-    List<MessageStateMongoDocument> findByDeliveryTypeAndAfterObjectIdAsc(DeliveryType deliveryType, ObjectId objectId);
+    List<MessageStateMongoDocument> findByDeliveryTypeAndAfterObjectIdAsc(ObjectId objectId, DeliveryType deliveryType);
     @Query(value = "{'_id':  {$gt:  ?0}, deliveryType: ?1}", sort = "{timestamp: 1}")
-    Slice<MessageStateMongoDocument> findByDeliveryTypeAndAfterObjectIdAsc(DeliveryType deliveryType, ObjectId objectId, Pageable pageable);
+    Slice<MessageStateMongoDocument> findByDeliveryTypeAndAfterObjectIdAsc(ObjectId objectId, DeliveryType deliveryType, Pageable pageable);
 
     @Query(value = "{status: {$in:  ?0}, deliveryType: ?1, subscriptionId: {$in:  ?2}}", sort = "{timestamp: 1}")
     List<MessageStateMongoDocument> findByStatusInAndDeliveryTypeAndSubscriptionIdsAsc(List<Status> status, DeliveryType deliveryType, List<String> subscriptionIds);