From 290f052bdcfa112292c891dc4f179e20bf06c812 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Thu, 13 Dec 2007 18:44:24 +0000 Subject: Some fixes relating to message 'staging'. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@603973 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/SemanticHandler.cpp | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'cpp/src/qpid/broker/SemanticHandler.cpp') diff --git a/cpp/src/qpid/broker/SemanticHandler.cpp b/cpp/src/qpid/broker/SemanticHandler.cpp index 768ea9ea08..32c032e701 100644 --- a/cpp/src/qpid/broker/SemanticHandler.cpp +++ b/cpp/src/qpid/broker/SemanticHandler.cpp @@ -40,6 +40,7 @@ using namespace qpid::sys; SemanticHandler::SemanticHandler(SessionState& s) : state(*this,s), session(s), + msgBuilder(&s.getBroker().getStore(), s.getBroker().getStagingThreshold()), ackOp(boost::bind(&SemanticState::ackRange, &state, _1, _2)) {} @@ -150,7 +151,7 @@ void SemanticHandler::handleContent(AMQFrame& frame) msg = msgBuilder.getMessage(); } msgBuilder.handle(frame); - if (msg->getFrames().isComplete()) {//end of frameset will be indicated by frame flags + if (frame.getEof() && frame.getEos()) {//end of frameset will be indicated by frame flags msg->setPublisher(&session.getConnection()); state.handle(msg); msgBuilder.end(); -- cgit v1.2.1