[jboss-svn-commits] JBL Code SVN: r7641 - labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/util

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

Author: daniel.brum at jboss.com
Date: 2006-11-16 09:09:09 -0500 (Thu, 16 Nov 2006)
New Revision: 7641

Modified:
   labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/util/Launcher.java
Log:


Modified: labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/util/Launcher.java
===================================================================
--- labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/util/Launcher.java	2006-11-16 13:13:32 UTC (rev 7640)
+++ labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/util/Launcher.java	2006-11-16 14:09:09 UTC (rev 7641)
@@ -1,8 +1,11 @@
 package org.jboss.soa.esb.samples.trailblazer.util;
 
 import java.io.File;
+import java.io.InputStream;
 import java.sql.Connection;
+import java.sql.DriverManager;
 import java.sql.Statement;
+import java.util.Properties;
 
 import org.apache.log4j.Logger;
 import org.apache.log4j.xml.DOMConfigurator;
@@ -10,6 +13,7 @@
 import org.jboss.soa.esb.common.Configuration;
 import org.jboss.soa.esb.listeners.gateway.GatewayListenerController;
 import org.jboss.soa.esb.listeners.message.EsbListenerController;
+import org.jboss.soa.esb.testutils.HsqldbUtil;
 import org.jboss.soa.esb.testutils.TestEnvironmentUtil;
 
 
@@ -39,6 +43,7 @@
 	private void triggerListener(long runTime, String messageAwareConfigFile, String gatewayConfigFile) throws Exception{
 		try 
         {
+			//setupRegistry();
 			runBeforeAllTests();
 			
 			
@@ -71,6 +76,7 @@
         }
         catch (Exception e) { 
         	_logger.error(e);
+        	e.printStackTrace();
         	throw(e);
         }
         finally { 
@@ -79,52 +85,61 @@
 	
 
 	}
-		
-//	private static void sendOneMessage() throws Exception{		
-//		Message msg = MessageFactory.getInstance().getMessage();
-//		msg.getBody().setContents("Foooooooooooooo".getBytes());		
-//		try {
-//			_epr = EsbListenerController.getEprManager().loadEPR(SERVICE_NAME); //TODO: replace with a real registry lookup
-//		}catch(Exception e) {	
-//			System.out.println("nobody servicing service " + SERVICE_NAME);
-//			return;
-//		}
-//		Courier courier = CourierFactory.getCourier(_epr);
-//		courier.deliver(msg);
-//		
-//	}
 	
 protected static void runBeforeAllTests() throws Exception{	
-//	System.setProperty("com.arjuna.common.util.propertyservice.verbosePropertyManager", "on");
+	//System.setProperty("com.arjuna.common.util.propertyservice.verbosePropertyManager", "on");
 	DOMConfigurator.configure("log4j.xml");
+//	TestEnvironmentUtil.setESBPropertiesFileToUse();
 	if (Configuration.getStoreDriver().equals("org.hsqldb.jdbcDriver")) {
+		
+		//start hsqldb
+		HsqldbUtil.startHsqldb("../../build/hsqldb", "jbossesb");
 //		HsqldbUtil.startHsqldb(TestEnvironmentUtil.getUserDir() + "build/hsqltestdb", "jbossesb");
-		HsqldbUtil.startHsqldb("../../build/hsqltestdb", "jbossesb");
-		//Get the registry-schema create scripts
-		String database = "hsqldb";
+		String database = "hsqldb";	
+		
+		
+		//message store db
+		String sqlDir = "../../install/message-store/sql/" + database + "/";
 //		String sqlDir = TestEnvironmentUtil.getUserDir() + "install/message-store/sql/" + database + "/";
-		String sqlDir = "../../install/message-store/sql/" + database + "/";
-		//Drop what is there now, if exists. We want to start fresh.				
 		String sqlCreateCmd    = TestEnvironmentUtil.readTextFile(new File(sqlDir + "create_database.sql"));
-		String sqlDropCmd      = TestEnvironmentUtil.readTextFile(new File(sqlDir + "drop_database.sql"));
+		String sqlDropCmd      = TestEnvironmentUtil.readTextFile(new File(sqlDir + "drop_database.sql"));		
 		
 		DBConnectionManager mgr = DBConnectionManager.getInstance();
 		Connection con = mgr.getConnection();
+		
 		Statement stmnt = con.createStatement();
-		System.out.println("Dropping the schema if exist");
+		System.out.println("Dropping the message store schema if exists...");
 		stmnt.execute(sqlDropCmd);
-		System.out.println("Creating the message store schema");
+		System.out.println("Creating the message store schema...");
 		stmnt.execute(sqlCreateCmd);
+		
+		//registry DB
+		sqlDir = "../../install/jUDDI-registry/sql/" + database + "/";
+//		sqlDir = TestEnvironmentUtil.getUserDir() + "install/jUDDI-registry/sql/" + database + "/";
+		System.out.println("Dropping the registry schema if exists...");
+		sqlDropCmd      = TestEnvironmentUtil.readTextFile(new File(sqlDir + "drop_database.sql"));
+		stmnt.execute(sqlDropCmd);
+		System.out.println("creating the registry schema...");
+		sqlCreateCmd    = TestEnvironmentUtil.readTextFile(new File(sqlDir + "create_database.sql"));
+		stmnt.execute(sqlCreateCmd);
+		System.out.println("inserting registry publishers...");
+		String sqlInsertPubCmd = TestEnvironmentUtil.readTextFile(new File(sqlDir + "insert_publishers.sql"));
+		stmnt.execute(sqlInsertPubCmd);
+		stmnt.close();
+		con.close();
 	}
 		
 	}
 	
 	private static void runAfterAllTests() throws Exception{
 		
+		//shutdown message store if using hsqldb
 		if (Configuration.getStoreDriver().equals("org.hsqldb.jdbcDriver")) {
 			HsqldbUtil.stopHsqldb(Configuration.getStoreUrl(),
 					Configuration.getStoreUser(),Configuration.getStorePwd() );
-		}
+			}
 	}
+	
+	
 
 }