svn commit: r578891 - in /incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network: Assembler.java Disassembler.java

[rhs]

Author: rhs
Date: Mon Sep 24 10:54:47 2007
New Revision: 578891

URL: http://svn.apache.org/viewvc?rev=578891&view=rev
Log:
switched to one byte for class/method ids

Modified:
    
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/Assembler.java
    
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/Disassembler.java

Modified: 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/Assembler.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/Assembler.java?rev=578891&r1=578890&r2=578891&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/Assembler.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/Assembler.java
 Mon Sep 24 10:54:47 2007
@@ -165,7 +165,7 @@
         switch (type)
         {
         case Frame.METHOD:
-            int methodType = (int) dec.readLong();
+            int methodType = dec.readShort();
             Method method = Method.create(methodType);
             method.read(dec, major, minor);
             return method;

Modified: 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/Disassembler.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/Disassembler.java?rev=578891&r1=578890&r2=578891&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/Disassembler.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/Disassembler.java
 Mon Sep 24 10:54:47 2007
@@ -110,14 +110,14 @@
     public void method(ConnectionEvent event, Method method)
     {
         SizeEncoder sizer = new SizeEncoder(major, minor);
-        sizer.writeLong(method.getEncodedType());
+        sizer.writeShort(method.getEncodedType());
         method.write(sizer, major, minor);
         sizer.flush();
         int size = sizer.getSize();
 
         ByteBuffer buf = ByteBuffer.allocate(size);
         BBEncoder enc = new BBEncoder(major, minor, buf);
-        enc.writeLong(method.getEncodedType());
+        enc.writeShort(method.getEncodedType());
         method.write(enc, major, minor);
         enc.flush();
         buf.flip();