[Cse-ip-svn-commits] SF.net SVN: cse-ip:[23] cse-ip/trunk/sandbox/cse-ip/ica-his-lsf/src/test/ java/de/campussource/cse/CamelTest.java

[<ro...@us...>]

Revision: 23
          http://cse-ip.svn.sourceforge.net/cse-ip/?rev=23&view=rev
Author:   roekens
Date:     2009-02-20 15:47:29 +0000 (Fri, 20 Feb 2009)

Log Message:
-----------
fixing test, in porgress
test seems to work so far, but still some activemq exceptions prevent correct running

Modified Paths:
--------------
    cse-ip/trunk/sandbox/cse-ip/ica-his-lsf/src/test/java/de/campussource/cse/CamelTest.java

Modified: cse-ip/trunk/sandbox/cse-ip/ica-his-lsf/src/test/java/de/campussource/cse/CamelTest.java
===================================================================
--- cse-ip/trunk/sandbox/cse-ip/ica-his-lsf/src/test/java/de/campussource/cse/CamelTest.java	2009-02-20 15:46:26 UTC (rev 22)
+++ cse-ip/trunk/sandbox/cse-ip/ica-his-lsf/src/test/java/de/campussource/cse/CamelTest.java	2009-02-20 15:47:29 UTC (rev 23)
@@ -8,24 +8,22 @@
 import java.io.InputStreamReader;
 import java.util.List;
 
-import org.apache.camel.CamelContext;
 import org.apache.camel.EndpointInject;
-import org.apache.camel.Exchange;
 import org.apache.camel.Produce;
 import org.apache.camel.ProducerTemplate;
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.component.mock.MockEndpoint;
+import org.apache.camel.spring.SpringCamelContext;
 import org.apache.log4j.Logger;
 import org.junit.Before;
 import org.junit.Test;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.test.annotation.DirtiesContext;
 import org.springframework.test.context.ContextConfiguration;
-import org.springframework.test.context.junit38.AbstractJUnit38SpringContextTests;
+import org.springframework.test.context.junit4.AbstractJUnit4SpringContextTests;
 
 
 @ContextConfiguration(locations={"classpath:META-INF/camel-context.xml"})
-public class CamelTest extends AbstractJUnit38SpringContextTests{
+public class CamelTest extends AbstractJUnit4SpringContextTests{
 	
 	private static final Logger logger = Logger.getLogger(CamelTest.class);
 
@@ -36,41 +34,42 @@
     protected ProducerTemplate template;
     
     @Autowired
-    CamelContext camelContext;
+    SpringCamelContext camelContext;
 
+    protected RouteBuilder createRouteBuilder() throws Exception {
+        return new RouteBuilder() {
+            public void configure() {
+            	from("activemq:AccountMessageHansen").to("mock:transformationResult");
+            }
+        };
+    }
     
     @Before
     public void before(){
     	try {
-    		//adding route for testFirstSteps to camel Context
-			camelContext.stop();
-			RouteBuilder builder = new RouteBuilder() {
-			    public void configure() {
-			        from("activemq:AccountMessageHansen").to("mock:transformationResult");
-			    }
-			};
-			camelContext.addRoutes(builder);
-			camelContext.start();
+    		RouteBuilder newRoutes = createRouteBuilder();
+    		camelContext.addRoutes(newRoutes);
+    		
+    		logger.info("----------> routes set");
+    		//camelContext.start();
+    		logger.info("----------> camel context restarted");
+    		
 		} catch (Exception e) {
 			logger.error("Error setting up test case");
 		}
     }
     
     @Test
-    @DirtiesContext
     public void testFirstSteps() throws Exception {
     	String input = getLsfSyncMessage();
     	String output = getHansenMessage();
     	result.expectedBodiesReceived(output);
+    	logger.info("----------> sending message");
     	template.sendBody(input);
-    	
-    	List<Exchange> exchangeList =result.getExchanges() ;
-    	for (Exchange exchange : exchangeList){
-    		logger.debug("Received: " + exchange);
-    	}
+    	logger.info("----------> message send");
     	//for building purposes set to NOTsatisfied, test is not working
-    	result.setResultWaitTime(2000l);
-    	result.assertIsNotSatisfied();
+    	result.setResultWaitTime(8000L);
+    	result.assertIsSatisfied();
     }
 
     public String getLsfSyncMessage(){
@@ -78,7 +77,8 @@
     		return readFileAsString("messages/lsf-sync-msg-original.xml");
     	}
     	catch (IOException ioe){
-    		logger.debug(ioe.getStackTrace());
+    		logger.error("Could not retrieve lsf-sync-msg-original.xml");
+    		logger.error(ioe.getStackTrace());
     	}
     	return "";
     }
@@ -88,7 +88,8 @@
     		return readFileAsString("messages/Hansen.xml");
     	}
     	catch (IOException ioe){
-    		logger.debug(ioe.getStackTrace());
+    		logger.error("Could not retrieve Hansen.xml");
+    		logger.error(ioe.getStackTrace());
     	}
     	return "";
     }


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.