aboutsummaryrefslogtreecommitdiffstats
path: root/vespaclient-java
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2019-04-14 09:07:04 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2019-04-14 09:07:04 +0200
commit85962336458e1a33aa5f0f0130dc018d4bee7d72 (patch)
tree53bd67071186bb84d2581f8cc34b9a9f41f0a3d4 /vespaclient-java
parent4932df60a5ead7cdc58a236663a58afdd936fb1d (diff)
Add control for if you want to use mbus threas for compression/encoding or your own.
Diffstat (limited to 'vespaclient-java')
-rwxr-xr-xvespaclient-java/src/main/java/com/yahoo/dummyreceiver/DummyReceiver.java2
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);