activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r525544 - /activemq/camel/trunk/camel-itest/src/main/java/org/apache/camel/itest/jms/JmsIntegrationTest.java
Date Wed, 04 Apr 2007 15:52:58 GMT
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();
+    }
 }



Mime
View raw message