diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2019-04-14 09:07:04 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2019-04-14 09:07:04 +0200 |
commit | 85962336458e1a33aa5f0f0130dc018d4bee7d72 (patch) | |
tree | 53bd67071186bb84d2581f8cc34b9a9f41f0a3d4 /vespaclient-java/src/main | |
parent | 4932df60a5ead7cdc58a236663a58afdd936fb1d (diff) |
Add control for if you want to use mbus threas for compression/encoding or your own.
Diffstat (limited to 'vespaclient-java/src/main')
-rwxr-xr-x | vespaclient-java/src/main/java/com/yahoo/dummyreceiver/DummyReceiver.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/vespaclient-java/src/main/java/com/yahoo/dummyreceiver/DummyReceiver.java b/vespaclient-java/src/main/java/com/yahoo/dummyreceiver/DummyReceiver.java index b1fd8e8cffa..3f0d167a12a 100755 --- a/vespaclient-java/src/main/java/com/yahoo/dummyreceiver/DummyReceiver.java +++ b/vespaclient-java/src/main/java/com/yahoo/dummyreceiver/DummyReceiver.java @@ -71,7 +71,7 @@ public class DummyReceiver implements MessageHandler { private void init() { MessageBusParams params = new MessageBusParams(new LoadTypeSet()); - params.setRPCNetworkParams(new RPCNetworkParams().setIdentity(new Identity(name))); + params.setRPCNetworkParams(new RPCNetworkParams().setIdentity(new Identity(name)).setSendInOwnThread(true)); params.setDocumentManagerConfigId("client"); params.getMessageBusParams().setMaxPendingCount(0); params.getMessageBusParams().setMaxPendingSize(0); |