You are viewing a plain text version of this content. The canonical link for it is here.
Posted to oak-commits@jackrabbit.apache.org by mi...@apache.org on 2022/11/15 15:06:29 UTC

[jackrabbit-oak] 01/01: change BlobRequestOptions for HA access

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

miroslav pushed a commit to branch enable_acces_from_secondary_storage_location
in repository https://gitbox.apache.org/repos/asf/jackrabbit-oak.git

commit f0f02a64178c88bbc10c95cf91c8814ec6708bf0
Author: smiroslav <mi...@apache.org>
AuthorDate: Tue Nov 15 16:05:58 2022 +0100

    change BlobRequestOptions for HA access
---
 .../oak/blob/cloud/azure/blobstorage/AzureBlobStoreBackend.java         | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/oak-blob-cloud-azure/src/main/java/org/apache/jackrabbit/oak/blob/cloud/azure/blobstorage/AzureBlobStoreBackend.java b/oak-blob-cloud-azure/src/main/java/org/apache/jackrabbit/oak/blob/cloud/azure/blobstorage/AzureBlobStoreBackend.java
index 4d94d94105..67fce0ad62 100644
--- a/oak-blob-cloud-azure/src/main/java/org/apache/jackrabbit/oak/blob/cloud/azure/blobstorage/AzureBlobStoreBackend.java
+++ b/oak-blob-cloud-azure/src/main/java/org/apache/jackrabbit/oak/blob/cloud/azure/blobstorage/AzureBlobStoreBackend.java
@@ -55,6 +55,7 @@ import com.google.common.collect.AbstractIterator;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
 import com.microsoft.azure.storage.AccessCondition;
+import com.microsoft.azure.storage.LocationMode;
 import com.microsoft.azure.storage.ResultContinuation;
 import com.microsoft.azure.storage.ResultSegment;
 import com.microsoft.azure.storage.RetryPolicy;
@@ -141,6 +142,7 @@ public class AzureBlobStoreBackend extends AbstractSharedBackend {
             requestOptions.setTimeoutIntervalInMs(requestTimeout);
         }
         requestOptions.setConcurrentRequestCount(concurrentRequestCount);
+        requestOptions.setLocationMode(LocationMode.PRIMARY_THEN_SECONDARY);
 
         return Utils.getBlobContainer(connectionString, containerName, requestOptions);
     }