This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new 283df7f7083 chore(deps): Bump mongo-java-driver-version from 5.2.1 to 
5.3.1 (#16909)
283df7f7083 is described below

commit 283df7f7083675ec6ec3f98518467d32cc7c761c
Author: Claus Ibsen <[email protected]>
AuthorDate: Sat Jan 25 10:03:24 2025 +0100

    chore(deps): Bump mongo-java-driver-version from 5.2.1 to 5.3.1 (#16909)
---
 .../kamelet/utils/mongodb/SslAwareMongoClient.java | 29 ++++++++++++++++++++++
 1 file changed, 29 insertions(+)

diff --git 
a/components/camel-kamelet/src/main/java/org/apache/camel/component/kamelet/utils/mongodb/SslAwareMongoClient.java
 
b/components/camel-kamelet/src/main/java/org/apache/camel/component/kamelet/utils/mongodb/SslAwareMongoClient.java
index d7b3819fb1d..e3d8e854492 100644
--- 
a/components/camel-kamelet/src/main/java/org/apache/camel/component/kamelet/utils/mongodb/SslAwareMongoClient.java
+++ 
b/components/camel-kamelet/src/main/java/org/apache/camel/component/kamelet/utils/mongodb/SslAwareMongoClient.java
@@ -30,6 +30,9 @@ import javax.net.ssl.X509TrustManager;
 
 import com.mongodb.*;
 import com.mongodb.client.*;
+import com.mongodb.client.model.bulk.ClientBulkWriteOptions;
+import com.mongodb.client.model.bulk.ClientBulkWriteResult;
+import com.mongodb.client.model.bulk.ClientNamespacedWriteModel;
 import com.mongodb.connection.ClusterDescription;
 import org.apache.camel.util.function.Suppliers;
 import org.bson.Document;
@@ -194,6 +197,32 @@ public class SslAwareMongoClient implements MongoClient {
         return getWrappedMongoClient().watch(clientSession, list, aClass);
     }
 
+    @Override
+    public ClientBulkWriteResult bulkWrite(List<? extends 
ClientNamespacedWriteModel> list) throws ClientBulkWriteException {
+        return getWrappedMongoClient().bulkWrite(list);
+    }
+
+    @Override
+    public ClientBulkWriteResult bulkWrite(
+            List<? extends ClientNamespacedWriteModel> list, 
ClientBulkWriteOptions clientBulkWriteOptions)
+            throws ClientBulkWriteException {
+        return getWrappedMongoClient().bulkWrite(list, clientBulkWriteOptions);
+    }
+
+    @Override
+    public ClientBulkWriteResult bulkWrite(ClientSession clientSession, List<? 
extends ClientNamespacedWriteModel> list)
+            throws ClientBulkWriteException {
+        return getWrappedMongoClient().bulkWrite(clientSession, list);
+    }
+
+    @Override
+    public ClientBulkWriteResult bulkWrite(
+            ClientSession clientSession, List<? extends 
ClientNamespacedWriteModel> list,
+            ClientBulkWriteOptions clientBulkWriteOptions)
+            throws ClientBulkWriteException {
+        return getWrappedMongoClient().bulkWrite(clientSession, list, 
clientBulkWriteOptions);
+    }
+
     @Override
     public ClusterDescription getClusterDescription() {
         return getWrappedMongoClient().getClusterDescription();

Reply via email to