diff options
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.java | 11 |
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)); |