aboutsummaryrefslogtreecommitdiffstats
path: root/config/src/test/java/com/yahoo/vespa/config/protocol/JRTConfigRequestFactoryTest.java
diff options
context:
space:
mode:
Diffstat (limited to 'config/src/test/java/com/yahoo/vespa/config/protocol/JRTConfigRequestFactoryTest.java')
-rw-r--r--config/src/test/java/com/yahoo/vespa/config/protocol/JRTConfigRequestFactoryTest.java11
1 files changed, 4 insertions, 7 deletions
diff --git a/config/src/test/java/com/yahoo/vespa/config/protocol/JRTConfigRequestFactoryTest.java b/config/src/test/java/com/yahoo/vespa/config/protocol/JRTConfigRequestFactoryTest.java
index 14183aa087a..4f7b1df5a43 100644
--- a/config/src/test/java/com/yahoo/vespa/config/protocol/JRTConfigRequestFactoryTest.java
+++ b/config/src/test/java/com/yahoo/vespa/config/protocol/JRTConfigRequestFactoryTest.java
@@ -2,11 +2,10 @@
package com.yahoo.vespa.config.protocol;
import com.yahoo.config.subscription.ConfigSourceSet;
-import com.yahoo.config.subscription.impl.JRTConfigRequester;
+import com.yahoo.config.subscription.ConfigSubscriber;
import com.yahoo.config.subscription.impl.JRTConfigSubscription;
import com.yahoo.foo.FunctionTestConfig;
import com.yahoo.vespa.config.ConfigKey;
-import com.yahoo.vespa.config.JRTConnectionPool;
import com.yahoo.vespa.config.RawConfig;
import com.yahoo.vespa.config.TimingValues;
import org.junit.Test;
@@ -43,13 +42,11 @@ public class JRTConfigRequestFactoryTest {
@Test
public void testCreateFromSub() {
+ ConfigSubscriber subscriber = new ConfigSubscriber();
Class<FunctionTestConfig> clazz = FunctionTestConfig.class;
final String configId = "foo";
- TimingValues timingValues = new TimingValues();
- JRTConfigSubscription<FunctionTestConfig> sub =
- new JRTConfigSubscription<>(new ConfigKey<>(clazz, configId),
- new JRTConfigRequester(new JRTConnectionPool(new ConfigSourceSet("tcp/localhost:12345")), timingValues),
- timingValues);
+ JRTConfigSubscription<FunctionTestConfig> sub = new JRTConfigSubscription<>(
+ new ConfigKey<>(clazz, configId), subscriber, new ConfigSourceSet(), new TimingValues());
JRTClientConfigRequest request = JRTConfigRequestFactory.createFromSub(sub);
assertThat(request.getVespaVersion().get(), is(defaultVespaVersion));