1 18 package org.apache.activemq.jndi; 19 20 import javax.naming.NamingException ; 21 22 import org.apache.activemq.ActiveMQConnectionFactory; 23 24 29 public class CustomConnectionFactoryNameTest extends ActiveMQInitialContextFactoryTest { 30 31 public void testConnectionFactoriesArePresent() throws NamingException { 32 super.testConnectionFactoriesArePresent(); 33 assertConnectionFactoryPresent("jms/Connection"); 34 assertConnectionFactoryPresent("jms/DURABLE_SUB_CONNECTION_FACTORY"); 35 } 36 37 public void testConnectionFactoriesAreConfigured() throws NamingException { 38 super.testConnectionFactoriesArePresent(); 39 ActiveMQConnectionFactory factory1 = (ActiveMQConnectionFactory) context.lookup("jms/Connection"); 40 assertNull(factory1.getClientID()); 41 ActiveMQConnectionFactory factory2 = (ActiveMQConnectionFactory) context.lookup("jms/DURABLE_SUB_CONNECTION_FACTORY"); 42 assertEquals("testclient", factory2.getClientID()); 43 } 44 45 protected String getConnectionFactoryLookupName() { 46 return "myConnectionFactory"; 47 } 48 49 protected void configureEnvironment() { 50 super.configureEnvironment(); 51 environment.put("connectionFactoryNames", " myConnectionFactory, jms/Connection, jms/DURABLE_SUB_CONNECTION_FACTORY"); 52 environment.put("connection.jms/DURABLE_SUB_CONNECTION_FACTORY.clientID", "testclient"); 53 } 54 } 55 | Popular Tags |