in extensions-core/core/deployment/src/main/java/org/apache/camel/quarkus/core/deployment/InjectionPointsProcessor.java [272:333]
void produceBeans(
CamelRecorder recorder,
Capabilities capabilities,
BuildProducer<SyntheticBeanBuildItem> syntheticBeans,
BuildProducer<NativeImageProxyDefinitionBuildItem> proxyDefinitions,
IndexView index,
AnnotationInstance annot,
FieldInfo field) {
try {
Type fieldType = field.type();
Class<?> clazz = Class.forName(fieldType.toString(), false,
Thread.currentThread().getContextClassLoader());
if (ProducerTemplate.class.isAssignableFrom(clazz)) {
syntheticBeans.produce(
SyntheticBeanBuildItem
.configure(fieldType.name())
.setRuntimeInit().scope(Singleton.class)
.supplier(
recorder.createProducerTemplate(resolveAnnotValue(index, annot)))
.addQualifier(annot)
.done());
/*
* Note that ProducerTemplate injection points not having @EndpointInject are produced via
* CamelProducers.camelProducerTemplate()
*/
} else if (FluentProducerTemplate.class.isAssignableFrom(clazz)) {
syntheticBeans.produce(
SyntheticBeanBuildItem
.configure(fieldType.name())
.setRuntimeInit().scope(Singleton.class)
.supplier(
recorder.createFluentProducerTemplate(resolveAnnotValue(index, annot)))
.addQualifier(annot)
.done());
/*
* Note that FluentProducerTemplate injection points not having @EndpointInject are produced via
* CamelProducers.camelFluentProducerTemplate()
*/
} else if (clazz.isInterface()) {
/* Requires camel-quarkus-bean */
if (capabilities.isMissing(CamelCapabilities.BEAN)) {
throw new IllegalStateException(
"Add camel-quarkus-bean dependency to be able to use @org.apache.camel.Produce on fields with interface type: "
+ fieldType.name()
+ " " + field.name() + " in "
+ field.declaringClass().name());
}
proxyDefinitions.produce(new NativeImageProxyDefinitionBuildItem(fieldType.name().toString()));
syntheticBeans.produce(
SyntheticBeanBuildItem
.configure(fieldType.name())
.setRuntimeInit().scope(Singleton.class)
.supplier(
recorder.produceProxy(clazz, resolveAnnotValue(index, annot)))
.addQualifier(annot)
.done());
}
} catch (ClassNotFoundException e) {
throw new RuntimeException(e);
}
}