diff --git a/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/Config.java b/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/Config.java index 139403b68..94b28c260 100644 --- a/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/Config.java +++ b/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/Config.java @@ -57,7 +57,6 @@ public final class Config { public static final String LRU_CACHE = CacheType.LRU.getValue(); static final String DEFAULT_CACHE = LRU_CACHE; - static final int DEFAULT_MAX_EVENT_STREAM_RETRIES = 7; static final int BASE_EVENT_STREAM_RETRY_BACKOFF_MS = 1000; static String fallBackToEnvOrDefault(String key, String defaultValue) { diff --git a/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/FlagdOptions.java b/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/FlagdOptions.java index e4f498915..a74222a1e 100644 --- a/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/FlagdOptions.java +++ b/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/FlagdOptions.java @@ -69,13 +69,6 @@ public class FlagdOptions { private int maxCacheSize = fallBackToEnvOrDefault(Config.MAX_CACHE_SIZE_ENV_VAR_NAME, Config.DEFAULT_MAX_CACHE_SIZE); - /** - * Max event stream connection retries. - */ - @Builder.Default - private int maxEventStreamRetries = fallBackToEnvOrDefault(Config.MAX_EVENT_STREAM_RETRIES_ENV_VAR_NAME, - Config.DEFAULT_MAX_EVENT_STREAM_RETRIES); - /** * Backoff interval in milliseconds. */ diff --git a/providers/flagd/src/test/java/dev/openfeature/contrib/providers/flagd/FlagdOptionsTest.java b/providers/flagd/src/test/java/dev/openfeature/contrib/providers/flagd/FlagdOptionsTest.java index 71adc687f..e0eb453a9 100644 --- a/providers/flagd/src/test/java/dev/openfeature/contrib/providers/flagd/FlagdOptionsTest.java +++ b/providers/flagd/src/test/java/dev/openfeature/contrib/providers/flagd/FlagdOptionsTest.java @@ -27,7 +27,6 @@ void TestDefaults() { assertNull(builder.getSocketPath()); assertEquals(DEFAULT_CACHE, builder.getCacheType()); assertEquals(DEFAULT_MAX_CACHE_SIZE, builder.getMaxCacheSize()); - assertEquals(DEFAULT_MAX_EVENT_STREAM_RETRIES, builder.getMaxEventStreamRetries()); assertNull(builder.getSelector()); assertNull(builder.getOpenTelemetry()); assertNull(builder.getCustomConnector()); @@ -48,7 +47,6 @@ void TestBuilderOptions() { .certPath("etc/cert/ca.crt") .cacheType("lru") .maxCacheSize(100) - .maxEventStreamRetries(1) .selector("app=weatherApp") .offlineFlagSourcePath("some-path") .openTelemetry(openTelemetry) @@ -64,7 +62,6 @@ void TestBuilderOptions() { assertEquals("etc/cert/ca.crt", flagdOptions.getCertPath()); assertEquals("lru", flagdOptions.getCacheType()); assertEquals(100, flagdOptions.getMaxCacheSize()); - assertEquals(1, flagdOptions.getMaxEventStreamRetries()); assertEquals("app=weatherApp", flagdOptions.getSelector()); assertEquals("some-path", flagdOptions.getOfflineFlagSourcePath()); assertEquals(openTelemetry, flagdOptions.getOpenTelemetry()); @@ -137,7 +134,6 @@ void usesSetOldAndNewName() { } - @Test void testInProcessProvider_noPortConfigured_defaultsToCorrectPort() { FlagdOptions flagdOptions = FlagdOptions.builder()