[james-project] 11/14: JAMES-3140: Implement CacheBlobStore

[btellier]

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

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

commit 86cb617b3e7eb0d3daa069b80bebab724fa0457e
Author: ducnv <duc91....@gmail.com>
AuthorDate: Fri Apr 24 13:51:16 2020 +0700

    JAMES-3140: Implement CacheBlobStore
---
 .../java/org/apache/james/blob/cassandra/cache/CachedBlobStore.java | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)

diff --git 
a/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/cache/CachedBlobStore.java
 
b/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/cache/CachedBlobStore.java
index d8fc908..ad73648 100644
--- 
a/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/cache/CachedBlobStore.java
+++ 
b/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/cache/CachedBlobStore.java
@@ -60,8 +60,7 @@ public class CachedBlobStore implements BlobStore {
 
         return Mono.just(bucketName)
             .filter(backend.getDefaultBucketName()::equals)
-            .flatMap(ignored ->
-                Mono.from(cache.read(blobId))
+            .flatMap(ignored -> Mono.from(cache.read(blobId))
                     .<InputStream>flatMap(bytes -> Mono.fromCallable(() -> new 
ByteArrayInputStream(bytes))))
             .switchIfEmpty(Mono.fromCallable(() -> backend.read(bucketName, 
blobId)))
             .blockOptional()
@@ -151,9 +150,6 @@ public class CachedBlobStore implements BlobStore {
         }
     }
 
-    /**
-     * bytes: byte[] from PushbackInputStream.If PushbackInputStream is empty 
bytes.length == 1
-     */
     private boolean isAbleToCache(BucketName bucketName, byte[] bytes, 
StoragePolicy storagePolicy) {
         return isAbleToCache(bucketName, storagePolicy) && bytes.length <= 
sizeThresholdInBytes;
     }


---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org
For additional commands, e-mail: server-dev-h...@james.apache.org