diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-09-15 17:48:01 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-09-15 17:48:01 +0200 |
commit | ea4ba360e06c8470b8608b238242fef7043283d7 (patch) | |
tree | 5da0978d07ff61f8041513cc65ca936e2f061fb5 /messagebus | |
parent | 95fb3d2771728609787cd2733613d019a5e45c5b (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.java | 8 |
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(); |