WebBrokerInitializerImpl.java 文件源码

@Override
// TODO throw corresponding exceptions, not just Exception instances.
protected BrokerService createBroker(ServletContext sc) throws Exception {
    // Initialize Web environment to make Spring resolve external
    // properties.
    StandardServletEnvironment standardServletEnvironment = new ReversePropertySourcesStandardServletEnvironment();
    WebApplicationContextUtils.initServletPropertySources(standardServletEnvironment.getPropertySources(), sc);

    URI configURI = new URI(standardServletEnvironment.getProperty(BROKER_URI_PROP));

    LOG.info("Loading message broker from: " + configURI);
    return BrokerFactory.createBroker(configURI);
}