New broker Messafe class handelrs added, removed old Basic* handlers; New framing Request and Response classes added

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@494541 13f79535-47bb-0310-9956-ffa450edef68

2 files changed, 7 insertions, 23 deletions

diff --git a/java/common/src/main/java/org/apache/qpid/framing/AMQRequest.java b/java/common/src/main/java/org/apache/qpid/framing/AMQRequestBody.java
index 821b5d177d..a60db0fa3f 100644
--- a/java/common/src/main/java/org/apache/qpid/framing/AMQRequest.java
+++ b/java/common/src/main/java/org/apache/qpid/framing/AMQRequestBody.java
@@ -22,7 +22,7 @@ package org.apache.qpid.framing;
 
 import org.apache.mina.common.ByteBuffer;
 
-public class AMQRequest extends AMQBody
+public class AMQRequestBody extends AMQBody
 {
     public static final byte TYPE = (byte)AmqpConstants.frameRequestAsInt();
        
@@ -33,7 +33,7 @@ public class AMQRequest extends AMQBody
 
 
     // Constructor
-    public AMQRequest() {}
+    public AMQRequestBody() {}
 
     // Field methods
     
@@ -72,7 +72,7 @@ public class AMQRequest extends AMQBody
     public static AMQFrame createAMQFrame(int channelId, long requestId,
             long responseMark, AMQMethodBody methodPayload)
     {
-        AMQResponse responseFrame = new AMQResponse();
+        AMQResponseBody responseFrame = new AMQResponseBody();
         responseFrame.requestId = requestId;
         responseFrame.responseMark = responseMark;
         responseFrame.methodPayload = methodPayload;
diff --git a/java/common/src/main/java/org/apache/qpid/framing/AMQResponse.java b/java/common/src/main/java/org/apache/qpid/framing/AMQResponseBody.java
index bf4bec8cda..c86bcbe2ad 100644
--- a/java/common/src/main/java/org/apache/qpid/framing/AMQResponse.java
+++ b/java/common/src/main/java/org/apache/qpid/framing/AMQResponseBody.java
@@ -22,36 +22,20 @@ package org.apache.qpid.framing;
 
 import org.apache.mina.common.ByteBuffer;
 
-public class AMQResponse extends AMQBody
+public class AMQResponseBody extends AMQRequestBody
 {
     public static final byte TYPE = (byte)AmqpConstants.frameResponseAsInt();
        
     // Fields declared in specification
-    public long requestId;
-    public long responseMark;
     public int batchOffset;
-    public AMQMethodBody methodPayload;
 
     // Constructor
-    public AMQResponse() {}
+    public AMQResponseBody() {}
 
     // Field methods
     
-    public long getRequestId() { return requestId; }
-    public long getResponseMark() { return responseMark; }
     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, requestId);
@@ -72,7 +56,7 @@ public class AMQResponse extends AMQBody
     public static AMQFrame createAMQFrame(int channelId, long requestId,
             long responseMark, int batchOffset, AMQMethodBody methodPayload)
     {
-        AMQResponse responseFrame = new AMQResponse();
+        AMQResponseBody responseFrame = new AMQResponseBody();
         responseFrame.requestId = requestId;
         responseFrame.responseMark = responseMark;
         responseFrame.batchOffset = batchOffset;