commit cdc1baa2ecfe5c38ffd6859c97428debc0282002
author Alan Conway <aconway@redhat.com> Sat Nov 12 00:51:46 2016 -0500
committer Alan Conway <aconway@redhat.com> Wed Nov 16 19:48:31 2016 -0500
tree ed0e60cb4cf8f8424d75d5a4e05e06f7f35fca28
parent b1a292503dc0dacf79fa55c53703f568f4c5b495

NO-JIRA: cpp example broker, set source address

examples/cpp/mt/broker.cpp

diff --git a/examples/cpp/mt/broker.cpp b/examples/cpp/mt/broker.cpp
index 39d7132..7ef90c3 100644
--- a/examples/cpp/mt/broker.cpp
+++ b/examples/cpp/mt/broker.cpp
@@ -26,6 +26,8 @@
 #include <proton/error_condition.hpp>
 #include <proton/listen_handler.hpp>
 #include <proton/messaging_handler.hpp>
+#include <proton/sender_options.hpp>
+#include <proton/source_options.hpp>
 #include <proton/thread_safe.hpp>
 
 #include <atomic>
@@ -151,6 +153,7 @@
     void on_sender_open(proton::sender &sender) OVERRIDE {
         queue *q = sender.source().dynamic() ?
             queues_.dynamic() : queues_.get(sender.source().address());
+        sender.open(proton::sender_options().source((proton::source_options().address(q->name()))));
         std::cout << "sending from " << q->name() << std::endl;
     }