[jboss-svn-commits] JBL Code SVN: r25263 - in labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta: tests/src/org/jboss/internal/soa/esb/rosetta/pooling and 1 other directory.

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

Author: mark.little at jboss.com
Date: 2009-02-14 05:14:40 -0500 (Sat, 14 Feb 2009)
New Revision: 25263

Modified:
   labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/internal/soa/esb/rosetta/pooling/JmsConnectionPoolContainer.java
   labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/internal/soa/esb/rosetta/pooling/JmsConnectionPoolContainerUnitTest.java
Log:
https://jira.jboss.org/jira/browse/JBESB-2383

Modified: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/internal/soa/esb/rosetta/pooling/JmsConnectionPoolContainer.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/internal/soa/esb/rosetta/pooling/JmsConnectionPoolContainer.java	2009-02-14 05:16:48 UTC (rev 25262)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/internal/soa/esb/rosetta/pooling/JmsConnectionPoolContainer.java	2009-02-14 10:14:40 UTC (rev 25263)
@@ -160,7 +160,7 @@
      */
     static Properties getJndiEnvironment(Map<String,String> poolKey) {
         Properties environment = new Properties();
-        final String[] jndiPrefixes = JMSEpr.getJndiPrefixes(environment.getProperty(JMSEpr.JNDI_PREFIXES)) ;
+        final String[] jndiPrefixes = JMSEpr.getJndiPrefixes(poolKey.get(JMSEpr.JNDI_PREFIXES)) ;
         for (String key: poolKey.keySet()) {
             for(String jndiPrefix: jndiPrefixes) {
                 if (key.startsWith(jndiPrefix)) {

Modified: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/internal/soa/esb/rosetta/pooling/JmsConnectionPoolContainerUnitTest.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/internal/soa/esb/rosetta/pooling/JmsConnectionPoolContainerUnitTest.java	2009-02-14 05:16:48 UTC (rev 25262)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/internal/soa/esb/rosetta/pooling/JmsConnectionPoolContainerUnitTest.java	2009-02-14 10:14:40 UTC (rev 25263)
@@ -78,6 +78,28 @@
 		assertEquals( password, poolKey.get( JMSEpr.JMS_SECURITY_CREDENTIAL_TAG ) );
 	}
 	
+	@Test
+	public void jndiPrefixes()
+	{
+		final String alternativePrefix = "alternative.naming." ;
+
+		final Properties env = new Properties() ;
+		env.put("java.naming.first", "first") ;
+		env.put("java.naming.second", "second") ;
+		env.put("java.naming.third", "third") ;
+		env.put(alternativePrefix + "first", "alternative first") ;
+		env.put(alternativePrefix + "second", "alternative second") ;
+		env.put(alternativePrefix + "third", "alternative third") ;
+		final Map<String, String> poolKey = JmsConnectionPoolContainer.createPoolKey(env, connectionFactory) ;
+		final Properties jndiEnv = JmsConnectionPoolContainer.getJndiEnvironment(poolKey) ;
+		assertEquals("Normal JNDI entries", 3, jndiEnv.size()) ;
+
+		env.put(JMSEpr.JNDI_PREFIXES, alternativePrefix) ;
+		final Map<String, String> alternativePoolKey = JmsConnectionPoolContainer.createPoolKey(env, connectionFactory) ;
+		final Properties alternativeJndiEnv = JmsConnectionPoolContainer.getJndiEnvironment(alternativePoolKey) ;
+		assertEquals("Alternative JNDI entries", 6, alternativeJndiEnv.size()) ;
+	}
+	
 	public static junit.framework.Test suite()
 	{
 		return new JUnit4TestAdapter( JmsConnectionPoolContainerUnitTest.class );