BytesMessage helper

This change adds a helper to get the bytes from BytesMessage. Borrowed from ByteArray.
belaban · Nov 19, 2024 · e577954 · e577954
1 parent 79d5b0d
commit e577954
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/src/org/jgroups/BytesMessage.java b/src/org/jgroups/BytesMessage.java
@@ -165,6 +165,15 @@ public BytesMessage setArray(ByteArray buf) {
         return this;
     }
 
+    public byte[] getBytes() {
+        if(array == null) return null;
+        if(offset == 0 && length == array.length)
+            return array;
+        byte[] tmp=new byte[length];
+        System.arraycopy(array, offset, tmp, 0, length);
+        return tmp;
+    }
+
 
 
     /**
@@ -219,7 +228,7 @@ public <T extends Object> T getObject(ClassLoader loader) {
         if(array == null)
             return null;
         try {
-            return isFlagSet(Flag.SERIALIZED)? Util.objectFromByteBuffer(array, offset, length, loader) : (T)getArray();
+            return isFlagSet(Flag.SERIALIZED)? Util.objectFromByteBuffer(array, offset, length, loader) : (T)getBytes();
         }
         catch(Exception ex) {
             throw new IllegalArgumentException(ex);