2 files changed, 6 insertions, 6 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 7488f5f13b..137ca1d0e4 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
@@ -71,15 +71,15 @@ public class AMQRequestBody extends AMQBody
     public static AMQFrame createAMQFrame(int channelId, long requestId,
             long responseMark, AMQMethodBody methodPayload)
     {
-        AMQResponseBody responseFrame = new AMQResponseBody();
-        responseFrame.requestId = requestId;
-        responseFrame.responseMark = responseMark;
-        responseFrame.methodPayload = methodPayload;
+        AMQRequestBody requestFrame = new AMQRequestBody();
+        requestFrame.requestId = requestId;
+        requestFrame.responseMark = responseMark;
+        requestFrame.methodPayload = methodPayload;
 
         
         AMQFrame frame = new AMQFrame();
         frame.channel = channelId;
-        frame.bodyFrame = responseFrame;
+        frame.bodyFrame = requestFrame;
         return frame;
     }
 }
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 3cb00a44c9..84174b4020 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
@@ -69,7 +69,7 @@ public class AMQResponseBody extends AMQBody
     }
     
     public static AMQFrame createAMQFrame(int channelId, long requestId,
-            long responseMark, int batchOffset, AMQMethodBody methodPayload)
+            long responseId, int batchOffset, AMQMethodBody methodPayload)
     {
         AMQResponseBody responseFrame = new AMQResponseBody();
         responseFrame.responseId = responseId;