diff options
| author | Henning Baldersheim <balder@yahoo-inc.com> | 2019-04-14 09:08:36 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-04-14 09:08:36 +0200 |
| commit | 7f3811147582723463eac67cc3416855f5138061 (patch) | |
| tree | 53bd67071186bb84d2581f8cc34b9a9f41f0a3d4 /container-messagebus | |
| parent | 94fce4f2d77fa2c771f143b1af91078cd4e19a54 (diff) | |
| parent | 85962336458e1a33aa5f0f0130dc018d4bee7d72 (diff) | |
Merge pull request #9126 from vespa-engine/balder/skip-the-messenger-thread
Balder/skip the messenger thread
Diffstat (limited to 'container-messagebus')
| -rw-r--r-- | container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/SessionCache.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/SessionCache.java b/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/SessionCache.java index 113d99f77f9..cd07a4b1f67 100644 --- a/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/SessionCache.java +++ b/container-messagebus/src/main/java/com/yahoo/container/jdisc/messagebus/SessionCache.java @@ -120,7 +120,8 @@ public final class SessionCache extends AbstractComponent { RPCNetworkParams netParams = new RPCNetworkParams() .setSlobrokConfigId(slobrokConfigId) .setIdentity(new Identity(identity)) - .setListenPort(mbusConfig.port()); + .setListenPort(mbusConfig.port()) + .setSendInOwnThread(true); return SharedMessageBus.newInstance(mbusParams, netParams); } |