ActiveMQContextListener.java 文件源码

/**
 * Factory method to create a new ActiveMQ Broker
 */
protected BrokerService createBroker(ServletContext context) {
    String brokerURI = context.getInitParameter(INIT_PARAM_BROKER_URI);
    if (brokerURI == null) {
        brokerURI = "activemq.xml";
    }
    context.log("Loading ActiveMQ Broker configuration from: " + brokerURI);
    Resource resource = new ServletContextResource(context, brokerURI);
    BrokerFactoryBean factory = new BrokerFactoryBean(resource);
    try {
        factory.afterPropertiesSet();
    } catch (Exception e) {
        context.log("Failed to create broker: " + e, e);
    }
    return factory.getBroker();
}