summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2013-07-30 16:58:14 +0000
committerGordon Sim <gsim@apache.org>2013-07-30 16:58:14 +0000
commit246bec77156ea51f8a00f32e78c819faaa08b7cc (patch)
treee9b4ebcca172bb43aba10c7cd5988c76da2136c5
parentde756778f91f7a8659a12c32df2424bd87bbe208 (diff)
downloadqpid-python-246bec77156ea51f8a00f32e78c819faaa08b7cc.tar.gz
QPID-5026: match source with target and vice-versa
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1508523 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--cpp/src/qpid/messaging/amqp/ReceiverContext.cpp1
-rw-r--r--cpp/src/qpid/messaging/amqp/SenderContext.cpp1
2 files changed, 2 insertions, 0 deletions
diff --git a/cpp/src/qpid/messaging/amqp/ReceiverContext.cpp b/cpp/src/qpid/messaging/amqp/ReceiverContext.cpp
index 081a0ae78b..c45368431c 100644
--- a/cpp/src/qpid/messaging/amqp/ReceiverContext.cpp
+++ b/cpp/src/qpid/messaging/amqp/ReceiverContext.cpp
@@ -96,6 +96,7 @@ void ReceiverContext::verify(pn_terminus_t* source)
void ReceiverContext::configure()
{
configure(pn_link_source(receiver));
+ pn_terminus_set_address(pn_link_target(receiver), pn_terminus_get_address(pn_link_source(receiver)));
}
void ReceiverContext::configure(pn_terminus_t* source)
{
diff --git a/cpp/src/qpid/messaging/amqp/SenderContext.cpp b/cpp/src/qpid/messaging/amqp/SenderContext.cpp
index d4a5ca4292..bc547dc561 100644
--- a/cpp/src/qpid/messaging/amqp/SenderContext.cpp
+++ b/cpp/src/qpid/messaging/amqp/SenderContext.cpp
@@ -506,6 +506,7 @@ void SenderContext::configure()
void SenderContext::configure(pn_terminus_t* target)
{
helper.configure(target, AddressHelper::FOR_SENDER);
+ pn_terminus_set_address(pn_link_source(sender), pn_terminus_get_address(pn_link_target(sender)));
}
bool SenderContext::settled()