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);