You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rh...@apache.org on 2007/09/24 19:54:47 UTC
svn commit: r578891 - in
/incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network:
Assembler.java Disassembler.java
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();