File tree Expand file tree Collapse file tree 2 files changed +5
-6
lines changed
providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd Expand file tree Collapse file tree 2 files changed +5
-6
lines changed Original file line number Diff line number Diff line change @@ -15,7 +15,7 @@ public final class Config {
1515
1616 static final int DEFAULT_DEADLINE = 500 ;
1717 static final int DEFAULT_STREAM_DEADLINE_MS = 10 * 60 * 1000 ;
18- static final int DEFAULT_STREAM_RETRY_GRACE_PERIOD = 50_000 ;
18+ static final int DEFAULT_STREAM_RETRY_GRACE_PERIOD = 50 ;
1919 static final int DEFAULT_MAX_CACHE_SIZE = 1000 ;
2020 static final long DEFAULT_KEEP_ALIVE = 0 ;
2121
@@ -36,7 +36,7 @@ public final class Config {
3636 static final String KEEP_ALIVE_MS_ENV_VAR_NAME_OLD = "FLAGD_KEEP_ALIVE_TIME" ;
3737 static final String KEEP_ALIVE_MS_ENV_VAR_NAME = "FLAGD_KEEP_ALIVE_TIME_MS" ;
3838 static final String TARGET_URI_ENV_VAR_NAME = "FLAGD_TARGET_URI" ;
39- static final String STREAM_RETRY_GRACE_PERIOD = "FLAGD_RETRY_GRACE_PERIOD_MS " ;
39+ static final String STREAM_RETRY_GRACE_PERIOD = "FLAGD_RETRY_GRACE_PERIOD " ;
4040
4141 static final String RESOLVER_RPC = "rpc" ;
4242 static final String RESOLVER_IN_PROCESS = "in-process" ;
Original file line number Diff line number Diff line change @@ -205,7 +205,7 @@ private synchronized void onReady() {
205205 */
206206 private synchronized void onConnectionLost () {
207207 log .debug ("Connection lost. Emit STALE event..." );
208- log .debug ("Waiting {}ms for connection to become available..." , gracePeriod );
208+ log .debug ("Waiting {}s for connection to become available..." , gracePeriod );
209209 connected = false ;
210210
211211 this .onConnectionEvent .accept (
@@ -219,12 +219,11 @@ private synchronized void onConnectionLost() {
219219 reconnectTask = reconnectExecutor .schedule (
220220 () -> {
221221 log .debug (
222- "Provider did not reconnect successfully within {}ms. Emit ERROR event..." ,
223- gracePeriod );
222+ "Provider did not reconnect successfully within {}s. Emit ERROR event..." , gracePeriod );
224223 this .onConnectionEvent .accept (new ConnectionEvent (false ));
225224 },
226225 gracePeriod ,
227- TimeUnit .MILLISECONDS );
226+ TimeUnit .SECONDS );
228227 }
229228 }
230229
You can’t perform that action at this time.
0 commit comments