diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2019-05-16 12:14:59 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2019-05-16 12:14:59 +0200 |
commit | 300018d38ec311e18a8f55b74e02ed1d533c8be0 (patch) | |
tree | 6f4da2e811b0f4e5ffab28d69b7a259dc774451a /messagebus/src | |
parent | ea1409bfa056576f7afa664553e58a7062afe542 (diff) | |
parent | 054d7eb5e02a66cab66c05d3a9a121cc5ab33639 (diff) |
Merge pull request #9431 from vespa-engine/balder/2-mbus-transport-threads
Use 2 threads for mbus transport.
Diffstat (limited to 'messagebus/src')
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java index 6b206435fa7..4a263aaae4c 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java @@ -37,7 +37,6 @@ import java.util.LinkedList; import java.util.List; import java.util.Map; import java.util.TreeMap; -import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.SynchronousQueue; import java.util.concurrent.ThreadPoolExecutor; @@ -83,7 +82,7 @@ public class RPCNetwork implements Network, MethodHandler { public RPCNetwork(RPCNetworkParams params, SlobrokConfigSubscriber slobrokConfig) { this.slobroksConfig = slobrokConfig; identity = params.getIdentity(); - orb = new Supervisor(new Transport()); + orb = new Supervisor(new Transport(2)); orb.setMaxInputBufferSize(params.getMaxInputBufferSize()); orb.setMaxOutputBufferSize(params.getMaxOutputBufferSize()); targetPool = new RPCTargetPool(params.getConnectionExpireSecs()); |