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