(james-project) branch master updated: [FIX] S3BlobStoreDAO::readReactive is blocking on the driver thread

[rc...@apache.org]

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


The following commit(s) were added to refs/heads/master by this push:
     new a482e80738 [FIX] S3BlobStoreDAO::readReactive is blocking on the driver thread
a482e80738 is described below

commit a482e807388400ad882bb4c93654c840fe86bfad
Author: Benoit TELLIER <bt...@linagora.com>
AuthorDate: Wed Mar 20 22:00:43 2024 +0100

    [FIX] S3BlobStoreDAO::readReactive is blocking on the driver thread
---
 .../java/org/apache/james/blob/objectstorage/aws/S3BlobStoreDAO.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git a/server/blob/blob-s3/src/main/java/org/apache/james/blob/objectstorage/aws/S3BlobStoreDAO.java b/server/blob/blob-s3/src/main/java/org/apache/james/blob/objectstorage/aws/S3BlobStoreDAO.java
index 8922f793fc..aaa7adfaf4 100644
--- a/server/blob/blob-s3/src/main/java/org/apache/james/blob/objectstorage/aws/S3BlobStoreDAO.java
+++ b/server/blob/blob-s3/src/main/java/org/apache/james/blob/objectstorage/aws/S3BlobStoreDAO.java
@@ -232,6 +232,7 @@ public class S3BlobStoreDAO implements BlobStoreDAO, Startable, Closeable {
         return getObject(resolvedBucketName, blobId)
             .onErrorMap(NoSuchBucketException.class, e -> new ObjectNotFoundException("Bucket not found " + resolvedBucketName.asString(), e))
             .onErrorMap(NoSuchKeyException.class, e -> new ObjectNotFoundException("Blob not found " + blobId.asString() + " in bucket " + resolvedBucketName.asString(), e))
+            .publishOn(ReactorUtils.BLOCKING_CALL_WRAPPER)
             .map(res -> ReactorUtils.toInputStream(res.flux));
     }
 


---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org