Replace standby blob chunk size configuration with feature flag
@@ -87,11 +87,6 @@ public class StandbyStoreService {
@Property(boolValue = SECURE_DEFAULT)
public static final String SECURE = "secure";
- public static final int BLOB_CHUNK_SIZE_DEFAULT = 1024 * 1024;
-
- @Property(intValue = BLOB_CHUNK_SIZE_DEFAULT)
- public static final String BLOB_CHUNK_SIZE = "blob.chunkSize";
-
public static final int READ_TIMEOUT_DEFAULT = 60000;
@Property(intValue = READ_TIMEOUT_DEFAULT)
@@ -105,6 +100,8 @@ public class StandbyStoreService {
@Reference(policy = STATIC, policyOption = GREEDY)
private SegmentStoreProvider storeProvider = null;
+ private static final int BLOB_CHUNK_SIZE = Integer.getInteger("oak.standby.blob.chunkSize", 1024 * 1024);
+
private final Closer closer = Closer.create();
@Activate
@@ -142,9 +139,8 @@ public class StandbyStoreService {
int port = PropertiesUtil.toInteger(props.get(PORT), PORT_DEFAULT);
String[] ranges = PropertiesUtil.toStringArray(props.get(ALLOWED_CLIENT_IP_RANGES), ALLOWED_CLIENT_IP_RANGES_DEFAULT);
boolean secure = PropertiesUtil.toBoolean(props.get(SECURE), SECURE_DEFAULT);
- int blobChunkSize = PropertiesUtil.toInteger(props.get(BLOB_CHUNK_SIZE), BLOB_CHUNK_SIZE_DEFAULT);
- StandbyServerSync standbyServerSync = new StandbyServerSync(port, fileStore, blobChunkSize, ranges, secure);
+ StandbyServerSync standbyServerSync = new StandbyServerSync(port, fileStore, BLOB_CHUNK_SIZE, ranges, secure);
closer.register(standbyServerSync);
standbyServerSync.start();
