I also noticed this commented out code:
public class ActiveMQInitialContextFactory implements InitialContextFactory
{
public Context getInitialContext(Hashtable environment) throws
NamingException {
// lets create a factory
Map data = new ConcurrentHashMap();
String[] names = getConnectionFactoryNames(environment);
for (int i = 0; i < names.length; i++) {
ActiveMQConnectionFactory factory =null;
String name = names[i];
try{
factory = createConnectionFactory(name, environment);
}catch(Exception e){
throw new NamingException("Invalid broker URL");
}
/* if( broker==null ) {
try {
broker = factory.getEmbeddedBroker();
}
catch (JMSException e) {
log.warn("Failed to get embedded broker", e);
}
}
*/
data.put(name,factory);
}
createQueues(data, environment);
createTopics(data, environment);
/*
if (broker != null) {
data.put("destinations",
broker.getDestinationContext(environment));
}
*/
...
Would that effect the broker from work?
--
View this message in context:
http://www.nabble.com/Using-ActiveMQ-embedded-sever-for-Testing-t1736053.html#a4733464
Sent from the ActiveMQ - User forum at Nabble.com.
