aboutsummaryrefslogtreecommitdiffstats
path: root/config
diff options
context:
space:
mode:
authorHarald Musum <musum@yahooinc.com>2021-12-03 13:28:31 +0100
committerHarald Musum <musum@yahooinc.com>2021-12-03 13:28:31 +0100
commitaa0376715ca4590f8b4c2a3e10b4f659e5eacf8d (patch)
tree2e36ca3fff953b74fc7a29871a8215fd0f235956 /config
parentdd8b7bd82a0327e6d4c1c7a08e3aa7625d475354 (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.java18
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);