From 24094828e39ba844f8724ab9f9f7c3e9209c2122 Mon Sep 17 00:00:00 2001 From: Jon Marius Venstad Date: Mon, 16 Aug 2021 21:00:25 +0200 Subject: Use injectable network multiplexer holder in SessionCache to bridge generations --- .../container/jdisc/messagebus/MbusClientProviderTest.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) (limited to 'container-messagebus/src/test/java/com/yahoo/container') 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(); -- cgit v1.2.3