diff options
author | Harald Musum <musum@yahooinc.com> | 2021-12-03 13:28:31 +0100 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2021-12-03 13:28:31 +0100 |
commit | aa0376715ca4590f8b4c2a3e10b4f659e5eacf8d (patch) | |
tree | 2e36ca3fff953b74fc7a29871a8215fd0f235956 /config | |
parent | dd8b7bd82a0327e6d4c1c7a08e3aa7625d475354 (diff) |
Remove useless test
We will never use more than one ConfigSourceSet for a GenericConfigSubscriber
Diffstat (limited to 'config')
-rw-r--r-- | config/src/test/java/com/yahoo/config/subscription/GenericConfigSubscriberTest.java | 18 |
1 files changed, 0 insertions, 18 deletions
diff --git a/config/src/test/java/com/yahoo/config/subscription/GenericConfigSubscriberTest.java b/config/src/test/java/com/yahoo/config/subscription/GenericConfigSubscriberTest.java index 4616630557e..5fada55be28 100644 --- a/config/src/test/java/com/yahoo/config/subscription/GenericConfigSubscriberTest.java +++ b/config/src/test/java/com/yahoo/config/subscription/GenericConfigSubscriberTest.java @@ -12,7 +12,6 @@ import com.yahoo.vespa.config.protocol.CompressionType; import org.junit.Test; import java.util.HashMap; -import java.util.LinkedHashMap; import java.util.List; import java.util.Map; @@ -60,23 +59,6 @@ public class GenericConfigSubscriberTest { return handle.getRawConfig().getPayload().withCompression(CompressionType.UNCOMPRESSED).toString(); } - @Test - public void testGenericRequesterPooling() { - ConfigSourceSet source1 = new ConfigSourceSet("tcp/foo:78"); - ConfigSourceSet source2 = new ConfigSourceSet("tcp/bar:79"); - JRTConfigRequester req1 = JRTConfigRequester.create(source1, tv); - JRTConfigRequester req2 = JRTConfigRequester.create(source2, tv); - Map<ConfigSourceSet, JRTConfigRequester> requesters = new LinkedHashMap<>(); - requesters.put(source1, req1); - requesters.put(source2, req2); - GenericConfigSubscriber sub = new GenericConfigSubscriber(requesters); - assertEquals(sub.requesters().get(source1).getConnectionPool().getCurrent().getAddress(), "tcp/foo:78"); - assertEquals(sub.requesters().get(source2).getConnectionPool().getCurrent().getAddress(), "tcp/bar:79"); - for (JRTConfigRequester requester : requesters.values()) { - requester.close(); - } - } - @Test(expected=UnsupportedOperationException.class) public void testOverriddenSubscribeInvalid1() { createSubscriber().subscribe(null, null); |