Skip to content

Commit 3d1bd46

Browse files
committed
Fix deprecations in MongoDb module
1 parent c05c310 commit 3d1bd46

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

spring-integration-mongodb/src/main/java/org/springframework/integration/mongodb/store/AbstractConfigurableMongoDbMessageStore.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -167,14 +167,14 @@ public void afterPropertiesSet() {
167167
protected void createIndexes() {
168168
IndexOperations indexOperations = this.mongoTemplate.indexOps(this.collectionName);
169169

170-
indexOperations.ensureIndex(new Index(MessageDocumentFields.MESSAGE_ID, Sort.Direction.ASC));
170+
indexOperations.createIndex(new Index(MessageDocumentFields.MESSAGE_ID, Sort.Direction.ASC));
171171

172-
indexOperations.ensureIndex(
172+
indexOperations.createIndex(
173173
new Index(MessageDocumentFields.GROUP_ID, Sort.Direction.ASC)
174174
.on(MessageDocumentFields.MESSAGE_ID, Sort.Direction.ASC)
175175
.unique());
176176

177-
indexOperations.ensureIndex(
177+
indexOperations.createIndex(
178178
new Index(MessageDocumentFields.GROUP_ID, Sort.Direction.ASC)
179179
.on(MessageDocumentFields.LAST_MODIFIED_TIME, Sort.Direction.DESC)
180180
.on(MessageDocumentFields.SEQUENCE, Sort.Direction.DESC));

spring-integration-mongodb/src/main/java/org/springframework/integration/mongodb/store/MongoDbChannelMessageStore.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -100,7 +100,7 @@ protected void createIndexes() {
100100
super.createIndexes();
101101
getMongoTemplate()
102102
.indexOps(this.collectionName)
103-
.ensureIndex(new Index(MessageDocumentFields.GROUP_ID, Sort.Direction.ASC)
103+
.createIndex(new Index(MessageDocumentFields.GROUP_ID, Sort.Direction.ASC)
104104
.on(MessageDocumentFields.PRIORITY, Sort.Direction.DESC)
105105
.on(MessageDocumentFields.LAST_MODIFIED_TIME, Sort.Direction.ASC)
106106
.on(MessageDocumentFields.SEQUENCE, Sort.Direction.ASC));

spring-integration-mongodb/src/main/java/org/springframework/integration/mongodb/store/MongoDbMessageStore.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -205,7 +205,7 @@ public void afterPropertiesSet() {
205205

206206
IndexOperations indexOperations = this.template.indexOps(this.collectionName);
207207

208-
indexOperations.ensureIndex(
208+
indexOperations.createIndex(
209209
new Index(GROUP_ID_KEY, Sort.Direction.ASC)
210210
.on(GROUP_UPDATE_TIMESTAMP_KEY, Sort.Direction.DESC)
211211
.on(SEQUENCE, Sort.Direction.DESC));

0 commit comments

Comments
 (0)