fix(split): adapt java client 2.0 version requests (#877)

XiaoMi · Aug 16, 2021 · f52a6a9 · f52a6a9
1 parent 6db3165
commit f52a6a9
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/runtime/rpc/rpc_message.cpp b/src/runtime/rpc/rpc_message.cpp
@@ -178,10 +178,11 @@ message_ex *message_ex::copy_message_no_reply(const message_ex &old_msg)
     }
 
     msg->header->body_length = msg->buffers[1].length();
+    msg->header->context.u.serialize_format = old_msg.header->context.u.serialize_format;
     msg->_is_read = true;
     msg->_rw_index = 1;
+    msg->_rw_offset = old_msg._rw_offset;
     msg->local_rpc_code = old_msg.local_rpc_code;
-    msg->header->context.u.serialize_format = old_msg.header->context.u.serialize_format;
     msg->add_ref();
 
     return msg;