Skip to content

Commit a3578cc

Browse files
chrfwowtoddbaert
andauthored
fix: stateBlockingQueue size increase to fix missed/delayed messages (#1422)
Signed-off-by: christian.lutnik <christian.lutnik@dynatrace.com> Co-authored-by: Todd Baert <todd.baert@dynatrace.com>
1 parent f6996dc commit a3578cc

File tree

1 file changed

+1
-1
lines changed
  • providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage

1 file changed

+1
-1
lines changed

providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/FlagStore.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ public class FlagStore implements Storage {
3434
private final WriteLock writeLock = sync.writeLock();
3535

3636
private final AtomicBoolean shutdown = new AtomicBoolean(false);
37-
private final BlockingQueue<StorageStateChange> stateBlockingQueue = new LinkedBlockingQueue<>(1);
37+
private final BlockingQueue<StorageStateChange> stateBlockingQueue = new LinkedBlockingQueue<>(4);
3838
private final Map<String, FeatureFlag> flags = new HashMap<>();
3939
private final Map<String, Object> flagSetMetadata = new HashMap<>();
4040

0 commit comments

Comments
 (0)