diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2021-08-27 10:18:20 +0200 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2021-08-27 10:18:20 +0200 |
commit | 420ce830ab41864a54e214098c4711340edd388c (patch) | |
tree | 829071d5f99291396c9283e66e691c4b06216201 /container-messagebus/src/main | |
parent | cde4273d98cbcef0576e37ece48d22554df20449 (diff) |
Fix unit test setup for docproc
Diffstat (limited to 'container-messagebus/src/main')
-rw-r--r-- | container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/NetworkMultiplexerProvider.java | 8 |
1 files 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()) |