summaryrefslogtreecommitdiffstats
path: root/container-messagebus
diff options
context:
space:
mode:
authorJon Marius Venstad <venstad@gmail.com>2021-08-27 10:18:20 +0200
committerJon Marius Venstad <venstad@gmail.com>2021-08-27 10:18:20 +0200
commit420ce830ab41864a54e214098c4711340edd388c (patch)
tree829071d5f99291396c9283e66e691c4b06216201 /container-messagebus
parentcde4273d98cbcef0576e37ece48d22554df20449 (diff)
Fix unit test setup for docproc
Diffstat (limited to 'container-messagebus')
-rw-r--r--container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/NetworkMultiplexerProvider.java8
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())