import org.apache.camel.spi.Injector; //导入依赖的package包/类
private ComponentProxyComponent resolveComponent(CamelContext context, Connector step) {
    ComponentProxyFactory factory = ComponentProxyComponent::new;

    if (step.getFactory() != null ) {
        final ClassResolver resolver = context.getClassResolver();
        final Injector injector = context.getInjector();

        Class<? extends ComponentProxyFactory> type = resolver.resolveClass(step.getFactory(), ComponentProxyFactory.class);
        if (type == null) {
            throw new IllegalArgumentException("Unable to resolve a ComponentProxyFactory of type: " + step.getFactory());
        }

        factory = injector.newInstance(type);
        if (factory == null) {
            throw new IllegalArgumentException("Unable to instantiate a ComponentProxyFactory of type: " + step.getFactory());
        }
    }

    return factory.newInstance(step.getComponentId(), step.getComponentScheme());
}
 

import org.apache.camel.spi.Injector; //导入依赖的package包/类
public BaseTypeConverterRegistry(PackageScanClassResolver resolver, Injector injector, FactoryFinder factoryFinder) {
    this.resolver = resolver;
    this.injector = injector;
    this.factoryFinder = factoryFinder;
    this.typeConverterLoaders.add(new AnnotationTypeConverterLoader(resolver));

    // add to string first as it will then be last in the last as to string can nearly
    // always convert something to a string so we want it only as the last resort
    // ToStringTypeConverter should NOT allow to be promoted
    addFallbackTypeConverter(new ToStringTypeConverter(), false);
    // enum is okay to be promoted
    addFallbackTypeConverter(new EnumTypeConverter(), true);
    // arrays is okay to be promoted
    addFallbackTypeConverter(new ArrayTypeConverter(), true);
    // and future should also not allowed to be promoted
    addFallbackTypeConverter(new FutureTypeConverter(this), false);
    // add sync processor to async processor converter is to be promoted
    addFallbackTypeConverter(new AsyncProcessorTypeConverter(), true);
}
 

import org.apache.camel.spi.Injector; //导入依赖的package包/类
private <T> T newInstance(String key, Injector injector, String propertyPrefix, Class<T> expectedType)
    throws IOException, ClassNotFoundException {
    Class<?> type = findClass(key, propertyPrefix);
    Object value = injector.newInstance(type);
    if (expectedType.isInstance(value)) {
        return expectedType.cast(value);
    } else {
        throw new ClassCastException("Not instanceof " + expectedType.getName() + " value: " + value);
    }
}
 

import org.apache.camel.spi.Injector; //导入依赖的package包/类
/**
 * Lazily create a default implementation
 */
protected Injector createInjector() {
    FactoryFinder finder = getDefaultFactoryFinder();
    try {
        return (Injector) finder.newInstance("Injector");
    } catch (NoFactoryAvailableException e) {
        // lets use the default injector
        return new DefaultInjector(this);
    }
}
 

import org.apache.camel.spi.Injector; //导入依赖的package包/类
@SuppressWarnings("unchecked")
protected T createInstance(String name, URL url, Injector injector) {
    try {
        Properties properties = loadProperties(url);
        String classname = (String) properties.get("class");
        Class<?> type = bundle.loadClass(classname);
        if (!this.type.isAssignableFrom(type)) {
            throw new IllegalArgumentException("Type is not a " + this.type.getName() + " implementation. Found: " + type.getName());
        }
        return injector.newInstance((Class<T>) type);
    } catch (ClassNotFoundException e) {
        throw new IllegalArgumentException("Invalid URI, no " + this.type.getName() + " registered for scheme : " + name, e);
    }
}
 

import org.apache.camel.spi.Injector; //导入依赖的package包/类
public void testNewInstance() throws Exception {
    Injector injector = context.getInjector();

    MyFoo foo = injector.newInstance(MyFoo.class);
    foo.setName("Claus");

    MyFoo foo2 = injector.newInstance(MyFoo.class);
    assertNotSame(foo, foo2);

    assertEquals("Claus", foo.getName());
    assertNull(foo2.getName());
}
 

import org.apache.camel.spi.Injector; //导入依赖的package包/类
public void testSharedInstance() throws Exception {
    Injector injector = context.getInjector();

    MyBarSingleton bar = injector.newInstance(MyBarSingleton.class, new MyBarSingleton());
    bar.setName("Claus");

    MyBarSingleton bar2 = injector.newInstance(MyBarSingleton.class, bar);
    assertSame(bar, bar2);

    assertEquals("Claus", bar.getName());
    assertEquals("Claus", bar2.getName());
}
 

import org.apache.camel.spi.Injector; //导入依赖的package包/类
public OsgiTypeConverter(BundleContext bundleContext, CamelContext camelContext, Injector injector, FactoryFinder factoryFinder) {
    this.bundleContext = bundleContext;
    this.camelContext = camelContext;
    this.injector = injector;
    this.factoryFinder = factoryFinder;
    this.tracker = new ServiceTracker<TypeConverterLoader, Object>(bundleContext, TypeConverterLoader.class.getName(), this);
}
 

import org.apache.camel.spi.Injector; //导入依赖的package包/类
@Override
protected Injector createInjector() {
    if (applicationContext instanceof ConfigurableApplicationContext) {
        return new SpringInjector((ConfigurableApplicationContext)applicationContext);
    } else {
        LOG.warn("Cannot use SpringInjector as applicationContext is not a ConfigurableApplicationContext as its: "
                  + applicationContext);
        return super.createInjector();
    }
}
 

import org.apache.camel.spi.Injector; //导入依赖的package包/类
@Override
public Injector getInjector() {
    return injector;
}
 

import org.apache.camel.spi.Injector; //导入依赖的package包/类
@Override
public void setInjector(Injector injector) {
    this.injector = injector;
}
 

import org.apache.camel.spi.Injector; //导入依赖的package包/类
public LazyLoadingTypeConverter(PackageScanClassResolver resolver, Injector injector, FactoryFinder factoryFinder) {
    super(resolver, injector, factoryFinder);
}
 

import org.apache.camel.spi.Injector; //导入依赖的package包/类
public DefaultTypeConverter(PackageScanClassResolver resolver, Injector injector, FactoryFinder factoryFinder) {
    super(resolver, injector, factoryFinder);
}
 

import org.apache.camel.spi.Injector; //导入依赖的package包/类
public <T> List<T> newInstances(String key, Injector injector, Class<T> type) throws ClassNotFoundException, IOException {
    List<Class<T>> list = CastUtils.cast(findClasses(key));
    List<T> answer = new ArrayList<T>(list.size());
    answer.add(newInstance(key, injector, type));
    return answer;
}
 

import org.apache.camel.spi.Injector; //导入依赖的package包/类
public Injector getInjector() {
    if (injector == null) {
        injector = createInjector();
    }
    return injector;
}
 

import org.apache.camel.spi.Injector; //导入依赖的package包/类
public void setInjector(Injector injector) {
    this.injector = injector;
}
 

import org.apache.camel.spi.Injector; //导入依赖的package包/类
public void testInjectorIsDefaultByDefault() throws Exception {
    Injector injector = context.getInjector();
    assertIsInstanceOf(DefaultInjector.class, injector);
}
 

import org.apache.camel.spi.Injector; //导入依赖的package包/类
public GuiceInjector(com.google.inject.Injector injector) {
    this.injector = injector;
}
 

import org.apache.camel.spi.Injector; //导入依赖的package包/类
@Inject
public GuiceCamelContext(com.google.inject.Injector injector) {
    this.injector = injector;
}
 

import org.apache.camel.spi.Injector; //导入依赖的package包/类
@Override
@Inject(optional = true)
public void setInjector(Injector injector) {
    super.setInjector(injector);
}