summaryrefslogtreecommitdiffstats
path: root/container-messagebus/src/test/java/com
diff options
context:
space:
mode:
authorJon Marius Venstad <venstad@gmail.com>2021-08-16 21:00:25 +0200
committerJon Marius Venstad <venstad@gmail.com>2021-08-16 21:01:03 +0200
commit24094828e39ba844f8724ab9f9f7c3e9209c2122 (patch)
treee5683f8da8708d8d74bcaaf647cae722c5cea55c /container-messagebus/src/test/java/com
parentc5b3b3400d8cdd533008148cab04a1da0838bae1 (diff)
Use injectable network multiplexer holder in SessionCache to bridge generations
Diffstat (limited to 'container-messagebus/src/test/java/com')
-rw-r--r--container-messagebus/src/test/java/com/yahoo/container/jdisc/messagebus/MbusClientProviderTest.java10
1 files changed, 6 insertions, 4 deletions
diff --git a/container-messagebus/src/test/java/com/yahoo/container/jdisc/messagebus/MbusClientProviderTest.java b/container-messagebus/src/test/java/com/yahoo/container/jdisc/messagebus/MbusClientProviderTest.java
index 9512c1a4873..d36234b0ccb 100644
--- a/container-messagebus/src/test/java/com/yahoo/container/jdisc/messagebus/MbusClientProviderTest.java
+++ b/container-messagebus/src/test/java/com/yahoo/container/jdisc/messagebus/MbusClientProviderTest.java
@@ -9,6 +9,9 @@ import com.yahoo.container.jdisc.messagebus.SessionCache;
import com.yahoo.document.config.DocumentmanagerConfig;
import com.yahoo.documentapi.messagebus.protocol.DocumentProtocolPoliciesConfig;
import com.yahoo.messagebus.MessagebusConfig;
+import com.yahoo.messagebus.network.NetworkMultiplexer;
+import com.yahoo.messagebus.network.rpc.RPCNetwork;
+import com.yahoo.messagebus.shared.NullNetwork;
import com.yahoo.vespa.config.content.DistributionConfig;
import com.yahoo.vespa.config.content.LoadTypeConfig;
import org.junit.Test;
@@ -37,14 +40,13 @@ public class MbusClientProviderTest {
}
private void testClient(SessionConfig config) {
- SessionCache cache = new SessionCache(new ContainerMbusConfig.Builder().build(),
+ SessionCache cache = new SessionCache(NetworkMultiplexer.dedicated(new NullNetwork()),
+ new ContainerMbusConfig.Builder().build(),
new DocumentmanagerConfig.Builder().build(),
new LoadTypeConfig.Builder().build(),
- new SlobroksConfig.Builder().build(),
new MessagebusConfig.Builder().build(),
new DocumentProtocolPoliciesConfig.Builder().build(),
- new DistributionConfig.Builder().build(),
- "test");
+ new DistributionConfig.Builder().build());
MbusClientProvider p = new MbusClientProvider(cache, config);
assertNotNull(p.get());
p.deconstruct();