From 420ce830ab41864a54e214098c4711340edd388c Mon Sep 17 00:00:00 2001 From: Jon Marius Venstad Date: Fri, 27 Aug 2021 10:18:20 +0200 Subject: Fix unit test setup for docproc --- .../container/jdisc/messagebus/NetworkMultiplexerProvider.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/NetworkMultiplexerProvider.java b/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/NetworkMultiplexerProvider.java index a99ec27656c..86e482adc48 100644 --- a/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/NetworkMultiplexerProvider.java +++ b/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/NetworkMultiplexerProvider.java @@ -26,10 +26,14 @@ public class NetworkMultiplexerProvider { } public NetworkMultiplexerProvider(NetworkMultiplexerHolder net, ContainerMbusConfig mbusConfig, String identity) { - this.net = net.get(asParameters(mbusConfig, identity)); + this.net = net.get(asParameters(mbusConfig, identity).setSlobrokConfigId(identity)); } - public static RPCNetworkParams asParameters(ContainerMbusConfig mbusConfig, String identity) { + public static RPCNetworkParams asParameters(ContainerMbusConfig mbusConfig, SlobroksConfig slobroksConfig, String identity) { + return asParameters(mbusConfig, identity).setSlobroksConfig(slobroksConfig); + } + + private static RPCNetworkParams asParameters(ContainerMbusConfig mbusConfig, String identity) { return new RPCNetworkParams().setSlobrokConfigId(identity) .setIdentity(new Identity(identity)) .setListenPort(mbusConfig.port()) -- cgit v1.2.3