diff --git a/spring-integration-core/src/test/java/org/springframework/integration/bus/EventDrivenConsumerTests.java b/spring-integration-core/src/test/java/org/springframework/integration/bus/EventDrivenConsumerTests.java
index 6f07b13100..ada5a99296 100644
--- a/spring-integration-core/src/test/java/org/springframework/integration/bus/EventDrivenConsumerTests.java
+++ b/spring-integration-core/src/test/java/org/springframework/integration/bus/EventDrivenConsumerTests.java
@@ -92,6 +92,7 @@ public class EventDrivenConsumerTests {
 		assertTrue(maxActive.get() <= maxConcurrency);
 		assertTrue(averageActive > concurrency);
 		assertTrue(averageActive < maxActive.get());
+		bus.stop();
 	}
 
 }