diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2021-08-16 21:00:25 +0200 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2021-08-16 21:01:03 +0200 |
commit | 24094828e39ba844f8724ab9f9f7c3e9209c2122 (patch) | |
tree | e5683f8da8708d8d74bcaaf647cae722c5cea55c /container-messagebus/src/test/java/com/yahoo/container | |
parent | c5b3b3400d8cdd533008148cab04a1da0838bae1 (diff) |
Use injectable network multiplexer holder in SessionCache to bridge generations
Diffstat (limited to 'container-messagebus/src/test/java/com/yahoo/container')
-rw-r--r-- | container-messagebus/src/test/java/com/yahoo/container/jdisc/messagebus/MbusClientProviderTest.java | 10 |
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(); |