Added bus.stop() call.

2007-12-25 23:22:47 +00:00
parent ffc6955841
commit b73a946815
1 changed files with 1 additions and 0 deletions
--- 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();
 	}

 }