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())));
+        }
     }
 }

Reply via email to