- Fixed incorrect FragmentedMessage.copyPayload

belaban · Sep 27, 2023 · c088168 · c088168
1 parent c9df6d8
commit c088168
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/src/org/jgroups/FragmentedMessage.java b/src/org/jgroups/FragmentedMessage.java
@@ -37,6 +37,15 @@ public FragmentedMessage(Message original_msg, int off, int len) {
     public Supplier<Message> create()             {return FragmentedMessage::new;}
     protected int            sizeOfPayload()      {return Global.INT_SIZE + length;}
 
+    @Override
+    protected Message copyPayload(Message copy) {
+        FragmentedMessage msg=(FragmentedMessage)super.copyPayload(copy);
+        msg.offset=this.offset;
+        msg.length=this.length;
+        msg.original_msg=this.original_msg;
+        return msg;
+    }
+
     public void writePayload(DataOutput out) throws IOException {
         ByteArrayDataOutputStream bos=out instanceof ByteArrayDataOutputStream? (ByteArrayDataOutputStream)out : null;
         int size_pos=bos != null? bos.position() : -1;