You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by kp...@apache.org on 2007/01/09 21:07:53 UTC
svn commit: r494549 - in
/incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing:
AMQRequestBody.java AMQResponseBody.java
Author: kpvdr
Date: Tue Jan 9 12:07:52 2007
New Revision: 494549
URL: http://svn.apache.org/viewvc?view=rev&rev=494549
Log:
Corrected errors in AMQResponseBody
Modified:
incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQRequestBody.java
incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQResponseBody.java
Modified: incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQRequestBody.java
URL: http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQRequestBody.java?view=diff&rev=494549&r1=494548&r2=494549
==============================================================================
--- incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQRequestBody.java (original)
+++ incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQRequestBody.java Tue Jan 9 12:07:52 2007
@@ -36,7 +36,6 @@
public AMQRequestBody() {}
// Field methods
-
public long getRequestId() { return requestId; }
public long getResponseMark() { return responseMark; }
public AMQMethodBody getMethodPayload() { return methodPayload; }
Modified: incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQResponseBody.java
URL: http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQResponseBody.java?view=diff&rev=494549&r1=494548&r2=494549
==============================================================================
--- incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQResponseBody.java (original)
+++ incubator/qpid/branches/qpid.0-9/java/common/src/main/java/org/apache/qpid/framing/AMQResponseBody.java Tue Jan 9 12:07:52 2007
@@ -22,24 +22,39 @@
import org.apache.mina.common.ByteBuffer;
-public class AMQResponseBody extends AMQRequestBody
+public class AMQResponseBody extends AMQBody
{
public static final byte TYPE = (byte)AmqpConstants.frameResponseAsInt();
// Fields declared in specification
+ public long responseId;
+ public long requestId;
public int batchOffset;
+ public AMQMethodBody methodPayload;
// Constructor
public AMQResponseBody() {}
// Field methods
-
+ public long getResponseId() { return responseId; }
+ public long getRequestId() { return requestId; }
public int getBatchOffset() { return batchOffset; }
+ public AMQMethodBody getMethodPayload() { return methodPayload; }
+
+ protected byte getFrameType()
+ {
+ return TYPE;
+ }
+
+ protected int getSize()
+ {
+ return 8 + 8 + 4 + methodPayload.getBodySize();
+ }
protected void writePayload(ByteBuffer buffer)
{
+ EncodingUtils.writeLong(buffer, responseId);
EncodingUtils.writeLong(buffer, requestId);
- EncodingUtils.writeLong(buffer, responseMark);
EncodingUtils.writeUnsignedShort(buffer, batchOffset);
methodPayload.writePayload(buffer);
}
@@ -47,8 +62,8 @@
protected void populateFromBuffer(ByteBuffer buffer, long size)
throws AMQFrameDecodingException, AMQProtocolVersionException
{
+ responseId = EncodingUtils.readLong(buffer);
requestId = EncodingUtils.readLong(buffer);
- responseMark = EncodingUtils.readLong(buffer);
batchOffset = EncodingUtils.readShort(buffer);
methodPayload.populateFromBuffer(buffer, size - 8 - 8 - 4);
}
@@ -57,8 +72,8 @@
long responseMark, int batchOffset, AMQMethodBody methodPayload)
{
AMQResponseBody responseFrame = new AMQResponseBody();
+ responseFrame.responseId = responseId;
responseFrame.requestId = requestId;
- responseFrame.responseMark = responseMark;
responseFrame.batchOffset = batchOffset;
responseFrame.methodPayload = methodPayload;