aboutsummaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2019-04-20 16:16:01 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2019-04-20 16:16:01 +0000
commit54593cf18424ea883e89ad24b914b60eead55b79 (patch)
tree88bed24419425bb4ef2ba71e94395c1df3e9cbf7 /messagebus
parentb2421dbec063b9be46611b08e69c5407a151f778 (diff)
Let the sender do all the packing too.
Diffstat (limited to 'messagebus')
-rw-r--r--messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java2
1 files changed, 1 insertions, 1 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 fdd72c12532..ad28fe81196 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
@@ -257,7 +257,7 @@ public class RPCNetwork implements Network, MethodHandler {
String.format("An error occurred while resolving version of recipient(s) [%s] from host '%s'.",
buildRecipientListString(ctx), identity.getHostname()));
} else {
- executor.execute(new SendTask(owner.getProtocol(ctx.msg.getProtocol()), ctx));
+ new SendTask(owner.getProtocol(ctx.msg.getProtocol()), ctx).run();
}
}