From 3d1bd467859f049832c07bbda03592bffc23e33e Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Mon, 3 Mar 2025 08:33:38 -0500 Subject: [PATCH] Fix deprecations in MongoDb module --- .../store/AbstractConfigurableMongoDbMessageStore.java | 6 +++--- .../mongodb/store/MongoDbChannelMessageStore.java | 2 +- .../integration/mongodb/store/MongoDbMessageStore.java | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/spring-integration-mongodb/src/main/java/org/springframework/integration/mongodb/store/AbstractConfigurableMongoDbMessageStore.java b/spring-integration-mongodb/src/main/java/org/springframework/integration/mongodb/store/AbstractConfigurableMongoDbMessageStore.java index 3e23749141..be66610288 100644 --- a/spring-integration-mongodb/src/main/java/org/springframework/integration/mongodb/store/AbstractConfigurableMongoDbMessageStore.java +++ b/spring-integration-mongodb/src/main/java/org/springframework/integration/mongodb/store/AbstractConfigurableMongoDbMessageStore.java @@ -167,14 +167,14 @@ public abstract class AbstractConfigurableMongoDbMessageStore extends AbstractMe protected void createIndexes() { IndexOperations indexOperations = this.mongoTemplate.indexOps(this.collectionName); - indexOperations.ensureIndex(new Index(MessageDocumentFields.MESSAGE_ID, Sort.Direction.ASC)); + indexOperations.createIndex(new Index(MessageDocumentFields.MESSAGE_ID, Sort.Direction.ASC)); - indexOperations.ensureIndex( + indexOperations.createIndex( new Index(MessageDocumentFields.GROUP_ID, Sort.Direction.ASC) .on(MessageDocumentFields.MESSAGE_ID, Sort.Direction.ASC) .unique()); - indexOperations.ensureIndex( + indexOperations.createIndex( new Index(MessageDocumentFields.GROUP_ID, Sort.Direction.ASC) .on(MessageDocumentFields.LAST_MODIFIED_TIME, Sort.Direction.DESC) .on(MessageDocumentFields.SEQUENCE, Sort.Direction.DESC)); diff --git a/spring-integration-mongodb/src/main/java/org/springframework/integration/mongodb/store/MongoDbChannelMessageStore.java b/spring-integration-mongodb/src/main/java/org/springframework/integration/mongodb/store/MongoDbChannelMessageStore.java index b9c0ed38b5..e556c19ccb 100644 --- a/spring-integration-mongodb/src/main/java/org/springframework/integration/mongodb/store/MongoDbChannelMessageStore.java +++ b/spring-integration-mongodb/src/main/java/org/springframework/integration/mongodb/store/MongoDbChannelMessageStore.java @@ -100,7 +100,7 @@ public class MongoDbChannelMessageStore extends AbstractConfigurableMongoDbMessa super.createIndexes(); getMongoTemplate() .indexOps(this.collectionName) - .ensureIndex(new Index(MessageDocumentFields.GROUP_ID, Sort.Direction.ASC) + .createIndex(new Index(MessageDocumentFields.GROUP_ID, Sort.Direction.ASC) .on(MessageDocumentFields.PRIORITY, Sort.Direction.DESC) .on(MessageDocumentFields.LAST_MODIFIED_TIME, Sort.Direction.ASC) .on(MessageDocumentFields.SEQUENCE, Sort.Direction.ASC)); diff --git a/spring-integration-mongodb/src/main/java/org/springframework/integration/mongodb/store/MongoDbMessageStore.java b/spring-integration-mongodb/src/main/java/org/springframework/integration/mongodb/store/MongoDbMessageStore.java index 62baaf27bb..3a6880e34a 100644 --- a/spring-integration-mongodb/src/main/java/org/springframework/integration/mongodb/store/MongoDbMessageStore.java +++ b/spring-integration-mongodb/src/main/java/org/springframework/integration/mongodb/store/MongoDbMessageStore.java @@ -205,7 +205,7 @@ public class MongoDbMessageStore extends AbstractMessageGroupStore IndexOperations indexOperations = this.template.indexOps(this.collectionName); - indexOperations.ensureIndex( + indexOperations.createIndex( new Index(GROUP_ID_KEY, Sort.Direction.ASC) .on(GROUP_UPDATE_TIMESTAMP_KEY, Sort.Direction.DESC) .on(SEQUENCE, Sort.Direction.DESC));