Decoupled routing from the channel and message classes.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@453657 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 6 insertions, 27 deletions

diff --git a/qpid/cpp/broker/src/Channel.cpp b/qpid/cpp/broker/src/Channel.cpp
index 4fb6a52b99..ae99f4e7fa 100644
--- a/qpid/cpp/broker/src/Channel.cpp
+++ b/qpid/cpp/broker/src/Channel.cpp
@@ -126,38 +126,17 @@ void Channel::ConsumerImpl::cancel(){
     if(queue) queue->cancel(this);
 }
 
-void Channel::handlePublish(Message* msg){
-    if(message.get()){
-        THROW_QPID_ERROR(PROTOCOL_ERROR + 504, "Invalid message sequence: got publish before previous content was completed.");
-    }
-    message = Message::shared_ptr(msg);
-}
-
-void Channel::handleHeader(AMQHeaderBody::shared_ptr header, ExchangeRegistry* exchanges){
+void Channel::checkMessage(const std::string& text){
     if(!message.get()){
-        THROW_QPID_ERROR(PROTOCOL_ERROR + 504, "Invalid message sequence: got header before publish.");
-    }
-    message->setHeader(header);
-    if(message->isComplete()){
-        publish(exchanges);
+        THROW_QPID_ERROR(PROTOCOL_ERROR + 504, text);
     }
 }
 
-void Channel::handleContent(AMQContentBody::shared_ptr content, ExchangeRegistry* exchanges){
-    if(!message.get()){
-        THROW_QPID_ERROR(PROTOCOL_ERROR + 504, "Invalid message sequence: got content before publish.");
-    }
-    message->addContent(content);
-    if(message->isComplete()){
-        publish(exchanges);
-    }
-}
-
-void Channel::publish(ExchangeRegistry* exchanges){
-    if(!route(message, exchanges)){
-        std::cout << "WARNING: Could not route message." << std::endl;
+void Channel::handlePublish(Message* msg){
+    if(message.get()){
+        THROW_QPID_ERROR(PROTOCOL_ERROR + 504, "Invalid message sequence: got publish before previous content was completed.");
     }
-    message.reset();
+    message = Message::shared_ptr(msg);
 }
 
 void Channel::ack(u_int64_t deliveryTag, bool multiple){