Author: bvahdat Date: Fri Sep 28 07:36:23 2012 New Revision: 1391346 URL: http://svn.apache.org/viewvc?rev=1391346&view=rev Log: Properly stop the services we create on our own.
Modified: camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/config/DualCamelContextEndpointOutsideTest.java Modified: camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/config/DualCamelContextEndpointOutsideTest.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/config/DualCamelContextEndpointOutsideTest.java?rev=1391346&r1=1391345&r2=1391346&view=diff ============================================================================== --- camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/config/DualCamelContextEndpointOutsideTest.java (original) +++ camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/config/DualCamelContextEndpointOutsideTest.java Fri Sep 28 07:36:23 2012 @@ -17,8 +17,10 @@ package org.apache.camel.spring.config; import org.apache.camel.CamelContext; +import org.apache.camel.ProducerTemplate; import org.apache.camel.component.mock.MockEndpoint; import org.apache.camel.spring.SpringTestSupport; +import org.apache.camel.util.ServiceHelper; import org.springframework.context.support.AbstractXmlApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; @@ -44,8 +46,14 @@ public class DualCamelContextEndpointOut MockEndpoint mockB = camelB.getEndpoint("mock:mock2", MockEndpoint.class); mockB.expectedBodiesReceived("Hello B"); - camelA.createProducerTemplate().sendBody("direct:start1", "Hello A"); - camelB.createProducerTemplate().sendBody("direct:start2", "Hello B"); + ProducerTemplate producer1 = camelA.createProducerTemplate(); + producer1.sendBody("direct:start1", "Hello A"); + + ProducerTemplate producer2 = camelB.createProducerTemplate(); + producer2.sendBody("direct:start2", "Hello B"); + + // make sure we properly stop the services we created + ServiceHelper.stopServices(producer1, producer2); mockA.assertIsSatisfied(); mockB.assertIsSatisfied();