[jboss-svn-commits] JBL Code SVN: r9943 - labs/jbossesb/trunk/product/core/services/tests/src/org/jboss/soa/esb/esb/persistence/tests.

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

Author: daniel.brum at jboss.com
Date: 2007-03-03 16:11:40 -0500 (Sat, 03 Mar 2007)
New Revision: 9943

Modified:
   labs/jbossesb/trunk/product/core/services/tests/src/org/jboss/soa/esb/esb/persistence/tests/MessageStoreUnitTest.java
Log:
modified to work with new connection pool manager

Modified: labs/jbossesb/trunk/product/core/services/tests/src/org/jboss/soa/esb/esb/persistence/tests/MessageStoreUnitTest.java
===================================================================
--- labs/jbossesb/trunk/product/core/services/tests/src/org/jboss/soa/esb/esb/persistence/tests/MessageStoreUnitTest.java	2007-03-03 21:11:21 UTC (rev 9942)
+++ labs/jbossesb/trunk/product/core/services/tests/src/org/jboss/soa/esb/esb/persistence/tests/MessageStoreUnitTest.java	2007-03-03 21:11:40 UTC (rev 9943)
@@ -39,11 +39,13 @@
 
 import junit.framework.JUnit4TestAdapter;
 
-import org.jboss.internal.soa.esb.persistence.format.db.DBConnectionManager;
+import org.jboss.internal.soa.esb.persistence.manager.ConnectionManager;
 import org.jboss.soa.esb.common.Configuration;
 import org.jboss.soa.esb.message.Message;
 import org.jboss.soa.esb.message.format.MessageFactory;
 import org.jboss.soa.esb.message.format.MessageType;
+import org.jboss.soa.esb.persistence.manager.ConnectionManagerException;
+import org.jboss.soa.esb.persistence.manager.ConnectionManagerFactory;
 import org.jboss.soa.esb.services.persistence.MessageStore;
 import org.jboss.soa.esb.services.persistence.MessageStoreFactory;
 import org.jboss.soa.esb.services.persistence.MessageStoreType;
@@ -70,8 +72,7 @@
 	public void testURIMessageStore ()
 	{
 		// only DB supported for now
-		MessageStore store1 = MessageStoreFactory.getInstance()
-				.getMessageStore(MessageStoreType.DATABASE);
+		MessageStore store1 = MessageStoreFactory.getInstance().getMessageStore(MessageStoreType.DATABASE);
 		assertEquals((store1 != null), true);
 	}
 
@@ -138,7 +139,13 @@
 		MessageStore store = MessageStoreFactory.getInstance().getMessageStore(
 				MessageStoreType.DATABASE);
 		assertEquals((store != null), true);
-		DBConnectionManager mgr = DBConnectionManager.getInstance();
+		ConnectionManager mgr=null;
+		try {
+			mgr = ConnectionManagerFactory.getConnectionManager();
+		} catch (ConnectionManagerException e) {
+			// TODO Auto-generated catch block
+//			e.printStackTrace();
+		}
 		assertEquals((mgr != null), true);
 	}
 
@@ -169,13 +176,13 @@
 				}
 				catch (Exception e)
 				{
-					System.out
-							.println("ERROR: failed to load " + database + " JDBC driver.");
+					System.out.println("ERROR: failed to load " + database + " JDBC driver.");
 					e.printStackTrace();
 					return;
 				}
 
-				DBConnectionManager mgr = DBConnectionManager.getInstance();
+				ConnectionManager mgr = ConnectionManagerFactory.getConnectionManager();
+				assertEquals((mgr != null), true);
 				Connection con = mgr.getConnection();
 				Statement stmnt = con.createStatement();
 				System.out.println("Dropping the schema if exist");
@@ -186,7 +193,7 @@
 		}
 		catch (Exception e)
 		{ // 
-			e.printStackTrace();
+//			e.printStackTrace();
 			System.out
 					.println("We should stop testing, since we don't have a db.");
 			assertTrue(false);