First version of RequestResponseHandler for an idea of how the RequestResponse frames will be managed... Not quite complete, still need to find a means of writing the frames that is common to both client and server.

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

1 files changed, 36 insertions, 37 deletions

diff --git a/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java b/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
index c5b45659cf..51be0d867b 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
@@ -170,49 +170,48 @@ public class AMQChannel
         _prefetch_HighWaterMark = prefetchCount;
     }
 
-
     public void setPublishFrame(BasicPublishBody publishBody, AMQProtocolSession publisher) throws AMQException
     {
         _currentMessage = new AMQMessage(_messageStore, publishBody);
         _currentMessage.setPublisher(publisher);
     }
 
-    public void publishContentHeader(ContentHeaderBody contentHeaderBody)
-            throws AMQException
-    {
-        if (_currentMessage == null)
-        {
-            throw new AMQException("Received content header without previously receiving a BasicDeliver frame");
-        }
-        else
-        {
-            _currentMessage.setContentHeaderBody(contentHeaderBody);
-            // check and route if header says body length is zero
-            if (contentHeaderBody.bodySize == 0)
-            {
-                routeCurrentMessage();
-            }
-        }
-    }
-
-    public void publishContentBody(ContentBody contentBody)
-            throws AMQException
-    {
-        if (_currentMessage == null)
-        {
-            throw new AMQException("Received content body without previously receiving a JmsPublishBody");
-        }
-        if (_currentMessage.getContentHeaderBody() == null)
-        {
-            throw new AMQException("Received content body without previously receiving a content header");
-        }
-
-        _currentMessage.addContentBodyFrame(contentBody);
-        if (_currentMessage.isAllContentReceived())
-        {
-            routeCurrentMessage();
-        }
-    }
+//     public void publishContentHeader(ContentHeaderBody contentHeaderBody)
+//             throws AMQException
+//     {
+//         if (_currentMessage == null)
+//         {
+//             throw new AMQException("Received content header without previously receiving a BasicDeliver frame");
+//         }
+//         else
+//         {
+//             _currentMessage.setContentHeaderBody(contentHeaderBody);
+//             // check and route if header says body length is zero
+//             if (contentHeaderBody.bodySize == 0)
+//             {
+//                 routeCurrentMessage();
+//             }
+//         }
+//     }
+// 
+//     public void publishContentBody(ContentBody contentBody)
+//             throws AMQException
+//     {
+//         if (_currentMessage == null)
+//         {
+//             throw new AMQException("Received content body without previously receiving a JmsPublishBody");
+//         }
+//         if (_currentMessage.getContentHeaderBody() == null)
+//         {
+//             throw new AMQException("Received content body without previously receiving a content header");
+//         }
+// 
+//         _currentMessage.addContentBodyFrame(contentBody);
+//         if (_currentMessage.isAllContentReceived())
+//         {
+//             routeCurrentMessage();
+//         }
+//     }
 
     protected void routeCurrentMessage() throws AMQException
     {