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

rcordier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git

commit eab7cb327d3a53de8967739443690efa6f630be8
Author: Rene Cordier <[email protected]>
AuthorDate: Tue Aug 1 10:45:33 2023 +0700

    JAMES-3929 Upgrade opensearch-java client to 2.6.0
---
 backends-common/opensearch/pom.xml                                     | 2 +-
 .../java/org/apache/james/backends/opensearch/OpenSearchIndexer.java   | 3 +--
 2 files changed, 2 insertions(+), 3 deletions(-)

diff --git a/backends-common/opensearch/pom.xml 
b/backends-common/opensearch/pom.xml
index c7c0c196b0..a0cd0ef7f5 100644
--- a/backends-common/opensearch/pom.xml
+++ b/backends-common/opensearch/pom.xml
@@ -83,7 +83,7 @@
         <dependency>
             <groupId>org.opensearch.client</groupId>
             <artifactId>opensearch-java</artifactId>
-            <version>2.1.0</version>
+            <version>2.6.0</version>
         </dependency>
         <dependency>
             <groupId>org.opensearch.client</groupId>
diff --git 
a/backends-common/opensearch/src/main/java/org/apache/james/backends/opensearch/OpenSearchIndexer.java
 
b/backends-common/opensearch/src/main/java/org/apache/james/backends/opensearch/OpenSearchIndexer.java
index 19c46e0dac..7f50c0eb3e 100644
--- 
a/backends-common/opensearch/src/main/java/org/apache/james/backends/opensearch/OpenSearchIndexer.java
+++ 
b/backends-common/opensearch/src/main/java/org/apache/james/backends/opensearch/OpenSearchIndexer.java
@@ -19,7 +19,6 @@
 package org.apache.james.backends.opensearch;
 
 import java.io.IOException;
-import java.util.Collections;
 import java.util.List;
 
 import org.apache.commons.lang3.StringUtils;
@@ -90,7 +89,7 @@ public class OpenSearchIndexer {
             op -> op.update(idx -> idx
                 .index(aliasName.getValue())
                 .id(updatedDocumentPart.getId().asString())
-                .document(Collections.singletonMap("doc", new 
RawValue(updatedDocumentPart.getUpdatedDocumentPart())))
+                .document(new 
RawValue(updatedDocumentPart.getUpdatedDocumentPart()))
                 .routing(routingKey.asString())
             )));
 


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to