BlueprintCamelContext.java 文件源码

@Override
public void serviceChanged(ServiceEvent event) {
    if (LOG.isDebugEnabled()) {
        LOG.debug("Service {} changed to {}", event, event.getType());
    }
    // look for blueprint container to be registered, and then we can start the CamelContext
    if (event.getType() == ServiceEvent.REGISTERED
            && event.getServiceReference().isAssignableTo(bundleContext.getBundle(), "org.osgi.service.blueprint.container.BlueprintContainer")
            && bundleContext.getBundle().equals(event.getServiceReference().getBundle())) {
        try {
            maybeStart();
        } catch (Exception e) {
            LOG.error("Error occurred during starting Camel: " + this + " due " + e.getMessage(), e);
        }
    }
}