diff options
| -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()) |