diff options
Diffstat (limited to 'java/common/src/main')
| -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() |
