diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2021-11-11 16:07:03 +0100 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2021-11-11 16:07:03 +0100 |
commit | 787329151b4940ef193d7e841e0fe2fd07a22f52 (patch) | |
tree | 8ca076b9d992af12ada2647a868938013d081fec /documentapi | |
parent | 5f896b2f66b395172c29fe7227d0f8c5efd8cb9d (diff) |
Use given messagebus config also when slobroks config is self-sub
Diffstat (limited to 'documentapi')
-rw-r--r-- | documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusDocumentAccess.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusDocumentAccess.java b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusDocumentAccess.java index f703b9ad59a..de09049b49e 100644 --- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusDocumentAccess.java +++ b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusDocumentAccess.java @@ -64,8 +64,9 @@ public class MessageBusDocumentAccess extends DocumentAccess { bus = new NetworkMessageBus(network, new MessageBus(network, mbusParams)); } else { - if (params.getRPCNetworkParams().getSlobroksConfig() != null && mbusParams.getMessageBusConfig() != null) + if (mbusParams.getMessageBusConfig() != null) { bus = new RPCMessageBus(mbusParams, params.getRPCNetworkParams()); + } else { log.log(Level.FINE, () -> "Setting up self-subscription to config because explicit config was missing; try to avoid this in containers"); bus = new RPCMessageBus(mbusParams, params.getRPCNetworkParams(), params.getRoutingConfigId()); |