summaryrefslogtreecommitdiff
path: root/java/common/src/main
diff options
context:
space:
mode:
Diffstat (limited to 'java/common/src/main')
-rw-r--r--java/common/src/main/java/org/apache/qpid/framing/AMQRequestBody.java4
-rw-r--r--java/common/src/main/java/org/apache/qpid/framing/AMQResponseBody.java4
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()