From 514eb084ebf4949da2422bc8ae2953d198131bb6 Mon Sep 17 00:00:00 2001 From: "christian.lutnik" Date: Tue, 17 Jun 2025 16:59:19 +0200 Subject: [PATCH] Increase the capacity of the stateBlockingQueue Signed-off-by: christian.lutnik --- .../providers/flagd/resolver/process/storage/FlagStore.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/FlagStore.java b/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/FlagStore.java index 04be543be..1f0b2290e 100644 --- a/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/FlagStore.java +++ b/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/FlagStore.java @@ -34,7 +34,7 @@ public class FlagStore implements Storage { private final WriteLock writeLock = sync.writeLock(); private final AtomicBoolean shutdown = new AtomicBoolean(false); - private final BlockingQueue stateBlockingQueue = new LinkedBlockingQueue<>(1); + private final BlockingQueue stateBlockingQueue = new LinkedBlockingQueue<>(4); private final Map flags = new HashMap<>(); private final Map flagSetMetadata = new HashMap<>();