You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by js...@apache.org on 2008/05/23 00:23:52 UTC

svn commit: r659282 - in /activemq/camel/trunk/components/camel-spring/src: main/java/org/apache/camel/spring/Main.java test/java/org/apache/camel/spring/debug/DebugTest.java

Author: jstrachan
Date: Thu May 22 15:23:51 2008
New Revision: 659282

URL: http://svn.apache.org/viewvc?rev=659282&view=rev
Log:
added a test case showing how to easily get the route definitions when running/debugging a route via the spring Main

Modified:
    activemq/camel/trunk/components/camel-spring/src/main/java/org/apache/camel/spring/Main.java
    activemq/camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/debug/DebugTest.java

Modified: activemq/camel/trunk/components/camel-spring/src/main/java/org/apache/camel/spring/Main.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-spring/src/main/java/org/apache/camel/spring/Main.java?rev=659282&r1=659281&r2=659282&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-spring/src/main/java/org/apache/camel/spring/Main.java (original)
+++ activemq/camel/trunk/components/camel-spring/src/main/java/org/apache/camel/spring/Main.java Thu May 22 15:23:51 2008
@@ -16,22 +16,12 @@
  */
 package org.apache.camel.spring;
 
-import java.io.IOException;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.LinkedList;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import java.util.concurrent.CountDownLatch;
-import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicBoolean;
-
 import org.apache.camel.CamelContext;
 import org.apache.camel.CamelTemplate;
-import org.apache.camel.processor.interceptor.Debugger;
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.impl.ServiceSupport;
+import org.apache.camel.model.RouteType;
+import org.apache.camel.processor.interceptor.Debugger;
 import org.apache.camel.util.ObjectHelper;
 import org.apache.camel.view.RouteDotGenerator;
 import org.apache.commons.logging.Log;
@@ -40,6 +30,12 @@
 import org.springframework.context.support.AbstractApplicationContext;
 import org.springframework.context.support.ClassPathXmlApplicationContext;
 
+import java.io.IOException;
+import java.util.*;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicBoolean;
+
 /**
  * A command line tool for booting up a CamelContext using an optional Spring
  * ApplicationContext
@@ -379,6 +375,14 @@
         return null;
     }
 
+    public List<RouteType> getRouteDefinitions() {
+        List<RouteType> answer = new ArrayList<RouteType>();
+        for (SpringCamelContext camelContext : camelContexts) {
+            answer.addAll(camelContext.getRouteDefinitions());
+        }
+        return answer;
+    }
+
     /**
      * Returns a {@link CamelTemplate} from the Spring {@link ApplicationContext} instances
      * or lazily creates a new one dynamically

Modified: activemq/camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/debug/DebugTest.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/debug/DebugTest.java?rev=659282&r1=659281&r2=659282&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/debug/DebugTest.java (original)
+++ activemq/camel/trunk/components/camel-spring/src/test/java/org/apache/camel/spring/debug/DebugTest.java Thu May 22 15:23:51 2008
@@ -25,6 +25,7 @@
 import org.apache.camel.spring.Main;
 import org.apache.camel.CamelTemplate;
 import org.apache.camel.Exchange;
+import org.apache.camel.model.RouteType;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
@@ -56,6 +57,10 @@
         DebugInterceptor o1 = assertHasInterceptor("o1");
         DebugInterceptor o2 = assertHasInterceptor("o2");
 
+        // now lets get the routes
+        List<RouteType> routes = main.getRouteDefinitions();
+        assertEquals("Number of routes", 1, routes.size());
+
         // now lets send a message
         CamelTemplate template = main.getCamelTemplate();
         template.sendBody("direct:a", expectedBody);