[jboss-svn-commits] JBL Code SVN: r6839 - labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/common

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

Author: daniel.brum at jboss.com
Date: 2006-10-16 17:15:27 -0400 (Mon, 16 Oct 2006)
New Revision: 6839

Modified:
   labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/common/Configuration.java
Log:
Message Store changes

Modified: labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/common/Configuration.java
===================================================================
--- labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/common/Configuration.java	2006-10-16 21:15:11 UTC (rev 6838)
+++ labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/common/Configuration.java	2006-10-16 21:15:27 UTC (rev 6839)
@@ -28,28 +28,33 @@
 {
 	private static KeyValuePair[] s_oaKV = new KeyValuePair[]
 	{
-			new KeyValuePair(Environment.SMTP_HOST, getSmtpHost()),
-			new KeyValuePair(Environment.SMTP_USERNAME, getSmtpUsername()),
-			new KeyValuePair(Environment.SMTP_PASSWORD, getSmtpPassword()),
-			new KeyValuePair(Environment.SMTP_PORT, getSmtpPort()),
-			new KeyValuePair(Environment.SMTP_FROM, getSmtpFrom()),
-			new KeyValuePair(Environment.SMTP_AUTH, getSmtpAuth()),
-			new KeyValuePair(Environment.JNDI_SERVER_TYPE, getJndiServerType()),
-			new KeyValuePair(Environment.JNDI_SERVER_URL, getJndiServerURL()),
-			new KeyValuePair(Environment.REGISTRY_QUERY_MANAGER_URI, getRegistryQueryManageURI()),
-			new KeyValuePair(Environment.REGISTRY_LIFECYCLE_MANAGER_URI, getRegistryLifecycleManagerURI()),
-			new KeyValuePair(Environment.REGISTRY_FACTORY_CLASS, getRegistryFactoryClass()),
-			new KeyValuePair(Environment.REGISTRY_USER, getRegistryUser()),
-			new KeyValuePair(Environment.REGISTRY_PASSWORD, getRegistryPassword()),
-			new KeyValuePair(Environment.REGISTRY_SCOUT_TRANSPORT_CLASS, getRegistryScoutTransportClass()),
-			new KeyValuePair(Environment.PARAMS_REPOS_IMPL_CLASS,
-					getParamRepositoryImplClass()),
-			new KeyValuePair(Environment.OBJECT_STORE_CONFIG_FILE, getObjStoreConfigFile()),
-			new KeyValuePair(Environment.ENCRYPT_FACTORY_CLASS, getEncryptionFactoryClass()),
-			new KeyValuePair(Environment.DB_DRIVER, getDbDriver()),
-			new KeyValuePair(Environment.DB_URL, getDbUrl()),
-			new KeyValuePair(Environment.DB_USER, getDbUser()),
-			new KeyValuePair(Environment.DB_PASSWORD, getDbPassword())
+			new KeyValuePair(Environment.SMTP_HOST, 					getSmtpHost()),
+			new KeyValuePair(Environment.SMTP_USERNAME, 				getSmtpUsername()),
+			new KeyValuePair(Environment.SMTP_PASSWORD, 				getSmtpPassword()),
+			new KeyValuePair(Environment.SMTP_PORT, 					getSmtpPort()),
+			new KeyValuePair(Environment.SMTP_FROM, 					getSmtpFrom()),
+			new KeyValuePair(Environment.SMTP_AUTH, 					getSmtpAuth()),
+			new KeyValuePair(Environment.JNDI_SERVER_TYPE, 				getJndiServerType()),
+			new KeyValuePair(Environment.JNDI_SERVER_URL, 				getJndiServerURL()),
+			new KeyValuePair(Environment.REGISTRY_QUERY_MANAGER_URI, 	getRegistryQueryManageURI()),
+			new KeyValuePair(Environment.REGISTRY_LIFECYCLE_MANAGER_URI,getRegistryLifecycleManagerURI()),
+			new KeyValuePair(Environment.REGISTRY_FACTORY_CLASS, 		getRegistryFactoryClass()),
+			new KeyValuePair(Environment.REGISTRY_USER, 				getRegistryUser()),
+			new KeyValuePair(Environment.REGISTRY_PASSWORD, 			getRegistryPassword()),
+			new KeyValuePair(Environment.REGISTRY_SCOUT_TRANSPORT_CLASS,getRegistryScoutTransportClass()),
+			new KeyValuePair(Environment.PARAMS_REPOS_IMPL_CLASS,		getParamRepositoryImplClass()),
+			new KeyValuePair(Environment.OBJECT_STORE_CONFIG_FILE, 		getObjStoreConfigFile()),
+			new KeyValuePair(Environment.ENCRYPT_FACTORY_CLASS, 		getEncryptionFactoryClass()),
+			new KeyValuePair(Environment.DB_DRIVER, 					getDbDriver()),
+			new KeyValuePair(Environment.DB_URL, 						getDbUrl()),
+			new KeyValuePair(Environment.DB_USER, 						getDbUser()),
+			new KeyValuePair(Environment.DB_PASSWORD, 					getDbPassword()),
+			new KeyValuePair(Environment.MSG_STORE_DB_CONNECTION_URL, 	getStoreUrl()),
+			new KeyValuePair(Environment.MSG_STORE_DB_JDBC_DRIVER, 		getStoreDriver()),
+			new KeyValuePair(Environment.MSG_STORE_DB_POOL_SIZE, 		getStorePoolSize()),
+			new KeyValuePair(Environment.MSG_STORE_DB_CONNECTION_USER, 	getStoreUser()),
+			new KeyValuePair(Environment.MSG_STORE_DB_CONNECTION_PWD, 	getStorePwd()),
+			new KeyValuePair(Environment.MSG_STORE_DB_VALIDATE_SQL, 	getStoreValidateSql()),
 
 	};
 
@@ -199,4 +204,39 @@
 		return property;
 	}
 	
+	public static String getStoreUrl()
+	{
+		String property = ModulePropertyManager.getPropertyManager(ModulePropertyManager.DBSTORE_MODULE).getProperty(Environment.MSG_STORE_DB_CONNECTION_URL);
+		return property;
+	}
+	
+	public static String getStoreDriver()
+	{
+		String property = ModulePropertyManager.getPropertyManager(ModulePropertyManager.DBSTORE_MODULE).getProperty(Environment.MSG_STORE_DB_JDBC_DRIVER);
+		return property;
+	}
+	
+	public static String getStorePoolSize()
+	{
+		String property = ModulePropertyManager.getPropertyManager(ModulePropertyManager.DBSTORE_MODULE).getProperty(Environment.MSG_STORE_DB_POOL_SIZE);
+		return property;
+	}
+	
+	public static String getStorePwd()
+	{
+		String property = ModulePropertyManager.getPropertyManager(ModulePropertyManager.DBSTORE_MODULE).getProperty(Environment.MSG_STORE_DB_CONNECTION_PWD);
+		return property;
+	}
+	
+	public static String getStoreUser()
+	{
+		String property = ModulePropertyManager.getPropertyManager(ModulePropertyManager.DBSTORE_MODULE).getProperty(Environment.MSG_STORE_DB_CONNECTION_USER);
+		return property;
+	}
+	
+	public static String getStoreValidateSql()
+	{
+		String property = ModulePropertyManager.getPropertyManager(ModulePropertyManager.DBSTORE_MODULE).getProperty(Environment.MSG_STORE_DB_VALIDATE_SQL);
+		return property;
+	}
 }
\ No newline at end of file