summaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2017-09-15 17:48:01 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2017-09-15 17:48:01 +0200
commitea4ba360e06c8470b8608b238242fef7043283d7 (patch)
tree5da0978d07ff61f8041513cc65ca936e2f061fb5 /messagebus
parent95fb3d2771728609787cd2733613d019a5e45c5b (diff)
body has moved to last 3 parameters.
Diffstat (limited to 'messagebus')
-rw-r--r--messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCSendV2.java8
1 files changed, 4 insertions, 4 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCSendV2.java b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCSendV2.java
index 409c7beee9b..8cc0b73ae30 100644
--- a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCSendV2.java
+++ b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCSendV2.java
@@ -110,8 +110,8 @@ public class RPCSendV2 extends RPCSend {
@Override
protected Reply createReply(Values ret, String serviceName, Trace trace) {
- CompressionType compression = CompressionType.valueOf(ret.get(0).asInt8());
- byte[] slimeBytes = compressor.decompress(ret.get(2).asData(), compression, ret.get(1).asInt32());
+ CompressionType compression = CompressionType.valueOf(ret.get(3).asInt8());
+ byte[] slimeBytes = compressor.decompress(ret.get(5).asData(), compression, ret.get(4).asInt32());
Slime slime = BinaryFormat.decode(slimeBytes);
Inspector root = slime.get();
@@ -151,8 +151,8 @@ public class RPCSendV2 extends RPCSend {
}
protected Params toParams(Values args) {
- CompressionType compression = CompressionType.valueOf(args.get(0).asInt8());
- byte[] slimeBytes = compressor.decompress(args.get(2).asData(), compression, args.get(1).asInt32());
+ CompressionType compression = CompressionType.valueOf(args.get(3).asInt8());
+ byte[] slimeBytes = compressor.decompress(args.get(5).asData(), compression, args.get(4).asInt32());
Slime slime = BinaryFormat.decode(slimeBytes);
Inspector root = slime.get();
Params p = new Params();