Author: rhs
Date: Wed Oct 3 10:41:07 2012
New Revision: 1393398
URL: http://svn.apache.org/viewvc?rev=1393398&view=rev
Log:
fixed outward munging
Modified:
qpid/proton/trunk/proton-c/src/messenger.c
Modified: qpid/proton/trunk/proton-c/src/messenger.c
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-c/src/messenger.c?rev=1393398&r1=1393397&r2=1393398&view=diff
==============================================================================
--- qpid/proton/trunk/proton-c/src/messenger.c (original)
+++ qpid/proton/trunk/proton-c/src/messenger.c Wed Oct 3 10:41:07 2012
@@ -528,7 +528,7 @@ static void outward_munge(pn_messenger_t
{
const char *address = pn_message_get_reply_to(msg);
int len = address ? strlen(address) : 0;
- if (len > 0 && address[0] != '/') {
+ if (len > 1 && address[0] == '~' && address[1] == '/') {
char buf[len + strlen(mng->name) + 4];
sprintf(buf, "amqp://%s/%s", mng->name, address);
pn_message_set_reply_to(msg, buf);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]