[jboss-svn-commits] JBL Code SVN: r7444 - labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/actions

[jboss-svn-commits at lists.jboss.org]

Author: kurt.stam at jboss.com
Date: 2006-11-07 14:38:42 -0500 (Tue, 07 Nov 2006)
New Revision: 7444

Modified:
   labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/actions/CbrProxyActionUnitTest.java
Log:
CBR replyListener

Modified: labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/actions/CbrProxyActionUnitTest.java
===================================================================
--- labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/actions/CbrProxyActionUnitTest.java	2006-11-07 19:31:13 UTC (rev 7443)
+++ labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/actions/CbrProxyActionUnitTest.java	2006-11-07 19:38:42 UTC (rev 7444)
@@ -22,12 +22,14 @@
 
 package org.jboss.soa.esb.actions;
 
+import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertTrue;
 
 import java.io.File;
 import java.io.InputStream;
 import java.sql.DriverManager;
 import java.sql.Statement;
+import java.util.Collection;
 import java.util.Properties;
 
 import junit.framework.JUnit4TestAdapter;
@@ -37,10 +39,11 @@
 import org.jboss.soa.esb.ConfigurationException;
 import org.jboss.soa.esb.common.tests.HsqldbUtil;
 import org.jboss.soa.esb.helpers.ConfigTree;
+import org.jboss.soa.esb.listeners.message.ActionProcessingPipeline;
 import org.jboss.soa.esb.listeners.message.EsbListenerController;
-import org.jboss.soa.esb.listeners.message.ActionProcessingPipeline;
 import org.jboss.soa.esb.message.Message;
 import org.jboss.soa.esb.message.format.MessageFactory;
+import org.jboss.soa.esb.services.routing.MessageRouter;
 import org.jboss.soa.esb.services.util.FileUtil;
 import org.jboss.soa.esb.util.TestUtil;
 import org.junit.AfterClass;
@@ -63,7 +66,7 @@
 	private static String mDbUsername;
 	private static String mDbPassword;
 	
-	
+	@Test
     public void routeAndDeliver() 
     {
 		try {
@@ -84,8 +87,8 @@
 			//give the CBR some time to finish
 			Thread.sleep(5000);
 		} catch (Exception e) {
+			e.printStackTrace();
 			assertTrue(false);
-			e.printStackTrace();
 		}
     }
 	
@@ -107,11 +110,18 @@
 				e.printStackTrace();
 			}
 			new Thread(chain).start();
+			Thread.sleep(5000);
+			//The message coming should have the Collection of destinationServices as a property.
+			Collection destinationServices = (Collection) chain.getMessage().getProperties().getProperty(MessageRouter.ROUTING_DESTINATION_SERVICE_LIST);
+			String firstDestination = (String) destinationServices.iterator().next();
+			logger.info("Destination=" + firstDestination);
+			assertEquals("test_category:JBOSS_XMLDestination",firstDestination);
+			
 			//give the CBR some time to finish
-			Thread.sleep(5000);
+			
 		} catch (Exception e) {
+			e.printStackTrace();
 			assertTrue(false);
-			e.printStackTrace();
 		}
     }