From 554b5d8aadb7a4ab8d734d284d4b0bf66b381b1c Mon Sep 17 00:00:00 2001 From: Kim van der Riet Date: Tue, 16 Jan 2007 22:10:07 +0000 Subject: 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 --- java/common/src/main/java/org/apache/qpid/framing/AMQRequestBody.java | 4 ++-- .../common/src/main/java/org/apache/qpid/framing/AMQResponseBody.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) (limited to 'java/common/src') 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() -- cgit v1.2.1