You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by as...@apache.org on 2013/07/03 22:00:17 UTC
svn commit: r1499540 -
/qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/OutgoingMessage.cpp
Author: astitcher
Date: Wed Jul 3 20:00:17 2013
New Revision: 1499540
URL: http://svn.apache.org/r1499540
Log:
QPID-4975: Only send correlation id if it isn't empty.
Modified:
qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/OutgoingMessage.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/OutgoingMessage.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/OutgoingMessage.cpp?rev=1499540&r1=1499539&r2=1499540&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/OutgoingMessage.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/OutgoingMessage.cpp Wed Jul 3 20:00:17 2013
@@ -52,7 +52,8 @@ void OutgoingMessage::convert(const qpid
//TODO: need to avoid copying as much as possible
message.setData(from.getContent());
message.getMessageProperties().setContentType(from.getContentType());
- message.getMessageProperties().setCorrelationId(from.getCorrelationId());
+ if ( !from.getCorrelationId().empty() )
+ message.getMessageProperties().setCorrelationId(from.getCorrelationId());
message.getMessageProperties().setUserId(from.getUserId());
const Address& address = from.getReplyTo();
if (address) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org