Author: jstrachan
Date: Wed Apr 4 08:52:57 2007
New Revision: 525544
URL: http://svn.apache.org/viewvc?view=rev&rev=525544
Log:
further spring cleaning; zapped the activate/deactivate methods on CamelContext as we have
the start/stop from Service
Modified:
activemq/camel/trunk/camel-itest/src/main/java/org/apache/camel/itest/jms/JmsIntegrationTest.java
Modified: activemq/camel/trunk/camel-itest/src/main/java/org/apache/camel/itest/jms/JmsIntegrationTest.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-itest/src/main/java/org/apache/camel/itest/jms/JmsIntegrationTest.java?view=diff&rev=525544&r1=525543&r2=525544
==============================================================================
--- activemq/camel/trunk/camel-itest/src/main/java/org/apache/camel/itest/jms/JmsIntegrationTest.java
(original)
+++ activemq/camel/trunk/camel-itest/src/main/java/org/apache/camel/itest/jms/JmsIntegrationTest.java
Wed Apr 4 08:52:57 2007
@@ -74,14 +74,14 @@
// lets add a jms -> pojo route
container.addRoutes(new RouteBuilder() {
public void configure() {
- from("jms:activemq:test").to("pojo:default:listener");
+ from("jms:test").to("pojo:listener");
}
});
- container.activateEndpoints();
+ container.start();
// Send a message to the JMS endpoint
- JmsEndpoint endpoint = (JmsEndpoint) container.resolveEndpoint("jms:activemq:test");
+ JmsEndpoint endpoint = (JmsEndpoint) container.resolveEndpoint("jms:test");
Producer<JmsExchange> producer = endpoint.createProducer();
JmsExchange exchange = producer.createExchange();
JmsMessage in = exchange.getIn();
@@ -92,8 +92,13 @@
// The Activated endpoint should send it to the pojo due to the configured route.
assertTrue("The message ware received by the Pojo", receivedCountDown.await(5, TimeUnit.SECONDS));
- container.deactivateEndpoints();
-
+
}
-
+
+ @Override
+ protected void tearDown() throws Exception {
+ container.stop();
+
+ super.tearDown();
+ }
}
|