diff options
| author | Kim van der Riet <kpvdr@apache.org> | 2007-01-16 22:10:07 +0000 |
|---|---|---|
| committer | Kim van der Riet <kpvdr@apache.org> | 2007-01-16 22:10:07 +0000 |
| commit | 554b5d8aadb7a4ab8d734d284d4b0bf66b381b1c (patch) | |
| tree | 24152a3dd3fcbc159f1ac61c5003831d69ce61ac /java/common/src | |
| parent | bc84e62cc549ac2d751a45d61a867354c84c60d6 (diff) | |
| download | qpid-python-554b5d8aadb7a4ab8d734d284d4b0bf66b381b1c.tar.gz | |
Created wiring to client RequestManagers and ResponseManagers, refactored all frame write code to use new write mechanisms.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@496873 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/common/src')
| -rw-r--r-- | java/common/src/main/java/org/apache/qpid/framing/AMQRequestBody.java | 4 | ||||
| -rw-r--r-- | java/common/src/main/java/org/apache/qpid/framing/AMQResponseBody.java | 4 |
2 files changed, 4 insertions, 4 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/framing/AMQRequestBody.java b/java/common/src/main/java/org/apache/qpid/framing/AMQRequestBody.java index 828941ed03..6df7dff27b 100644 --- a/java/common/src/main/java/org/apache/qpid/framing/AMQRequestBody.java +++ b/java/common/src/main/java/org/apache/qpid/framing/AMQRequestBody.java @@ -24,7 +24,7 @@ import org.apache.mina.common.ByteBuffer; public class AMQRequestBody extends AMQBody { - public static final byte TYPE = 9; + public static final byte TYPE = (byte)AmqpConstants.frameRequestAsInt(); // Fields declared in specification protected long requestId; @@ -51,7 +51,7 @@ public class AMQRequestBody extends AMQBody protected byte getFrameType() { - return (byte)AmqpConstants.frameRequestAsInt(); + return TYPE; } protected int getSize() diff --git a/java/common/src/main/java/org/apache/qpid/framing/AMQResponseBody.java b/java/common/src/main/java/org/apache/qpid/framing/AMQResponseBody.java index 63f3bf1133..9697b8bd33 100644 --- a/java/common/src/main/java/org/apache/qpid/framing/AMQResponseBody.java +++ b/java/common/src/main/java/org/apache/qpid/framing/AMQResponseBody.java @@ -24,7 +24,7 @@ import org.apache.mina.common.ByteBuffer; public class AMQResponseBody extends AMQBody { - public static final byte TYPE = 10; + public static final byte TYPE = (byte)AmqpConstants.frameResponseAsInt(); // Fields declared in specification protected long responseId; @@ -51,7 +51,7 @@ public class AMQResponseBody extends AMQBody protected byte getFrameType() { - return (byte)AmqpConstants.frameResponseAsInt(); + return TYPE; } protected int getSize() |