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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
