Diff of /tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/FragmentationInterceptor.java

Parent Directory | Revision Log | Patch

--- tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/FragmentationInterceptor.java	2006/03/01 14:52:47	382039
+++ tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/FragmentationInterceptor.java	2006/03/01 14:54:35	382040
@@ -56,8 +56,9 @@ public class FragmentationInterceptor ex
             frag(destination, msg, payload);
         }
         else {
-            byte[] flag = XByteBuffer.toBytes(frag);
-            msg.getMessage().append(flag,0,flag.length);
+            //byte[] flag = XByteBuffer.toBytes(frag);
+            //msg.getMessage().append(flag,0,flag.length);
+            msg.getMessage().append(frag);
             super.sendMessage(destination, msg, payload);
         }
     }
@@ -117,12 +118,15 @@ public class FragmentationInterceptor ex
             tmp.getMessage().clear();
             tmp.getMessage().append(msg.getMessage().getBytesDirect(),offset,length);
             //add the msg nr
-            tmp.getMessage().append(XByteBuffer.toBytes(i),0,4);
+            //tmp.getMessage().append(XByteBuffer.toBytes(i),0,4);
+            tmp.getMessage().append(i);
             //add the total nr of messages
-            tmp.getMessage().append(XByteBuffer.toBytes(count),0,4);
+            //tmp.getMessage().append(XByteBuffer.toBytes(count),0,4);
+            tmp.getMessage().append(count);
             //add true as the frag flag
-            byte[] flag = XByteBuffer.toBytes(true);
-            tmp.getMessage().append(flag,0,flag.length);
+            //byte[] flag = XByteBuffer.toBytes(true);
+            //tmp.getMessage().append(flag,0,flag.length);
+            tmp.getMessage().append(true);
             messages[i] = tmp;
             remaining -= length;