summaryrefslogtreecommitdiffstats
path: root/config
diff options
context:
space:
mode:
authorHarald Musum <musum@yahooinc.com>2021-10-05 08:50:45 +0200
committerHarald Musum <musum@yahooinc.com>2021-10-05 08:50:45 +0200
commitded986ab3813ae55978e8a2610bfa44a573c8710 (patch)
treeda9234669afbaa52d71896debbbd446177d5a841 /config
parentfc3bc61f4b70b39fb0296cd6a74c09603e6777a2 (diff)
Use interface in method signature
Diffstat (limited to 'config')
-rw-r--r--config/src/main/java/com/yahoo/config/subscription/impl/JRTConfigSubscription.java7
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) {