diff --git a/spring-integration-mongodb/src/test/java/org/springframework/integration/mongodb/rules/MongoDbAvailableTests.java b/spring-integration-mongodb/src/test/java/org/springframework/integration/mongodb/rules/MongoDbAvailableTests.java index e3f707c1ec..323bd1acca 100644 --- a/spring-integration-mongodb/src/test/java/org/springframework/integration/mongodb/rules/MongoDbAvailableTests.java +++ b/spring-integration-mongodb/src/test/java/org/springframework/integration/mongodb/rules/MongoDbAvailableTests.java @@ -50,6 +50,7 @@ public abstract class MongoDbAvailableTests { protected void cleanupCollections(MongoDbFactory mongoDbFactory, String... additionalCollectionsToDrop) { MongoTemplate template = new MongoTemplate(mongoDbFactory); template.dropCollection("messages"); + template.dropCollection("channelMessages"); template.dropCollection("configurableStoreMessages"); template.dropCollection("data"); for (String additionalCollection : additionalCollectionsToDrop) {