This is an automated email from the ASF dual-hosted git repository. lburgazzoli pushed a commit to branch quarkus-master in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit df734149a0b80c24c05ffbea9224984f0f165bcd Author: lburgazzoli <lburgazz...@gmail.com> AuthorDate: Fri Feb 7 10:49:27 2020 +0100 Fix MongoDbProcessor according to the latest changes in the mongodb extension --- .../component/mongodb/deployment/MongoDbProcessor.java | 16 ++++++++++++---- 1 file changed, 12 insertions(+), 4 deletions(-) diff --git a/extensions/mongodb/deployment/src/main/java/org/apache/camel/quarkus/component/mongodb/deployment/MongoDbProcessor.java b/extensions/mongodb/deployment/src/main/java/org/apache/camel/quarkus/component/mongodb/deployment/MongoDbProcessor.java index f14c0c9..29efc8f 100644 --- a/extensions/mongodb/deployment/src/main/java/org/apache/camel/quarkus/component/mongodb/deployment/MongoDbProcessor.java +++ b/extensions/mongodb/deployment/src/main/java/org/apache/camel/quarkus/component/mongodb/deployment/MongoDbProcessor.java @@ -16,7 +16,7 @@ */ package org.apache.camel.quarkus.component.mongodb.deployment; -import com.mongodb.MongoClient; +import io.quarkus.deployment.annotations.BuildProducer; import io.quarkus.deployment.annotations.BuildStep; import io.quarkus.deployment.annotations.ExecutionTime; import io.quarkus.deployment.annotations.Record; @@ -34,12 +34,20 @@ class MongoDbProcessor { return new FeatureBuildItem(FEATURE); } + // TODO: needs to be reviewed once https://github.com/quarkusio/quarkus/pull/7063 is merged @BuildStep @Record(ExecutionTime.RUNTIME_INIT) - CamelRuntimeBeanBuildItem registerCamelMongoClientProducer(MongoClientBuildItem mongoClientBuildItem, + void registerCamelMongoClientProducer( + MongoClientBuildItem mongoClient, + BuildProducer<CamelRuntimeBeanBuildItem> runtimeBeans, CamelMongoClientRecorder recorder) { - return new CamelRuntimeBeanBuildItem("camelMongoClient", MongoClient.class.getName(), - recorder.createCamelMongoClient(mongoClientBuildItem.getClient())); + if (mongoClient != null) { + runtimeBeans.produce( + new CamelRuntimeBeanBuildItem( + "camelMongoClient", + "com.mongodb.MongoClient", + recorder.createCamelMongoClient(mongoClient.getClient()))); + } } }