diff options
author | Harald Musum <musum@yahooinc.com> | 2021-10-05 08:50:45 +0200 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2021-10-05 08:50:45 +0200 |
commit | ded986ab3813ae55978e8a2610bfa44a573c8710 (patch) | |
tree | da9234669afbaa52d71896debbbd446177d5a841 /config/src/main/java | |
parent | fc3bc61f4b70b39fb0296cd6a74c09603e6777a2 (diff) |
Use interface in method signature
Diffstat (limited to 'config/src/main/java')
-rw-r--r-- | config/src/main/java/com/yahoo/config/subscription/impl/JRTConfigSubscription.java | 7 |
1 files changed, 3 insertions, 4 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 e83fc7aefc5..d8551c37f41 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 @@ -15,6 +15,7 @@ import com.yahoo.vespa.config.protocol.Payload; import java.time.Duration; import java.time.Instant; +import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.TimeUnit; @@ -39,7 +40,7 @@ public class JRTConfigSubscription<T extends ConfigInstance> extends ConfigSubsc * The queue containing either nothing or the one (newest) request that has got callback from JRT, * but has not yet been handled. */ - private LinkedBlockingQueue<JRTClientConfigRequest> reqQueue = new LinkedBlockingQueue<>(); + private BlockingQueue<JRTClientConfigRequest> reqQueue = new LinkedBlockingQueue<>(); private ConfigSourceSet sources; public JRTConfigSubscription(ConfigKey<T> key, ConfigSubscriber subscriber, ConfigSource source, TimingValues timingValues) { @@ -134,9 +135,7 @@ public class JRTConfigSubscription<T extends ConfigInstance> extends ConfigSubsc return configInstance; } - LinkedBlockingQueue<JRTClientConfigRequest> getReqQueue() { - return reqQueue; - } + BlockingQueue<JRTClientConfigRequest> getReqQueue() { return reqQueue; } @Override public boolean subscribe(long timeout) { |