Author: gsim
Date: Mon Jul 27 19:59:42 2015
New Revision: 1692937
URL: http://svn.apache.org/r1692937
Log:
QPID-6659: wait for full message before processing
Modified:
qpid/trunk/qpid/cpp/src/qpid/messaging/amqp/ConnectionContext.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/messaging/amqp/ConnectionContext.cpp
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/messaging/amqp/ConnectionContext.cpp?rev=1692937&r1=1692936&r2=1692937&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/messaging/amqp/ConnectionContext.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/messaging/amqp/ConnectionContext.cpp Mon Jul
27 19:59:42 2015
@@ -285,7 +285,7 @@ bool ConnectionContext::get(boost::share
checkClosed(ssn, lnk);
pn_delivery_t* current = pn_link_current((pn_link_t*) lnk->receiver);
QPID_LOG(debug, "In ConnectionContext::get(), current=" << current);
- if (current) {
+ if (current && !pn_delivery_partial(current)) {
qpid::messaging::MessageImpl& impl =
MessageImplAccess::get(message);
boost::shared_ptr<EncodedMessage> encoded(new
EncodedMessage(pn_delivery_pending(current)));
encoded->setNestAnnotationsOption(nestAnnotations);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
