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));