diff options
| author | Harald Musum <musum@yahooinc.com> | 2022-04-08 13:22:29 +0200 |
|---|---|---|
| committer | Harald Musum <musum@yahooinc.com> | 2022-04-08 13:22:29 +0200 |
| commit | 9e01e1ed649eb3a02f6004443e37db9e8a8ff901 (patch) | |
| tree | 574c2f9bb4ee3b9618864f6776934568482dee5b /config | |
| parent | ff7ca6c2fd5a96a26b65f70cf35af26393f2e8b3 (diff) | |
Synchronize when polling config response queue
Diffstat (limited to 'config')
| -rw-r--r-- | config/src/main/java/com/yahoo/config/subscription/impl/JRTConfigSubscription.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/config/src/main/java/com/yahoo/config/subscription/impl/JRTConfigSubscription.java b/config/src/main/java/com/yahoo/config/subscription/impl/JRTConfigSubscription.java index 90c538ac19b..abfbf2c6c79 100644 --- a/config/src/main/java/com/yahoo/config/subscription/impl/JRTConfigSubscription.java +++ b/config/src/main/java/com/yahoo/config/subscription/impl/JRTConfigSubscription.java @@ -68,7 +68,7 @@ public class JRTConfigSubscription<T extends ConfigInstance> extends ConfigSubsc return newConfigOrException(); } - private JRTClientConfigRequest pollForNewConfig(long timeoutMillis) { + private synchronized JRTClientConfigRequest pollForNewConfig(long timeoutMillis) { JRTClientConfigRequest response = pollQueue(timeoutMillis); // There might be more than one response on the queue, so empty queue by polling with // 0 timeout until queue is empty (returned value is null) |