diff options
| author | Gordon Sim <gsim@apache.org> | 2007-12-13 18:44:24 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2007-12-13 18:44:24 +0000 |
| commit | 290f052bdcfa112292c891dc4f179e20bf06c812 (patch) | |
| tree | df7e46a810194e03043395eb3c98c9cd1641faa2 /cpp/src/qpid/broker/SemanticHandler.cpp | |
| parent | d1910203a6803d4eed26d694909721e4a0142320 (diff) | |
| download | qpid-python-290f052bdcfa112292c891dc4f179e20bf06c812.tar.gz | |
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
Diffstat (limited to 'cpp/src/qpid/broker/SemanticHandler.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/SemanticHandler.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
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(); |