summaryrefslogtreecommitdiff
path: root/cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp')
-rw-r--r--cpp/src/qpid/client/ConnectionHandler.cpp2
-rw-r--r--cpp/src/qpid/client/FailoverListener.cpp9
-rw-r--r--cpp/src/qpid/client/FailoverListener.h2
3 files changed, 9 insertions, 4 deletions
diff --git a/cpp/src/qpid/client/ConnectionHandler.cpp b/cpp/src/qpid/client/ConnectionHandler.cpp
index b2245077e2..5fbe87878a 100644
--- a/cpp/src/qpid/client/ConnectionHandler.cpp
+++ b/cpp/src/qpid/client/ConnectionHandler.cpp
@@ -26,6 +26,7 @@
#include "qpid/framing/all_method_bodies.h"
#include "qpid/framing/ClientInvoker.h"
#include "qpid/framing/reply_exceptions.h"
+#include "qpid/log/Helpers.h"
using namespace qpid::client;
using namespace qpid::framing;
@@ -165,6 +166,7 @@ void ConnectionHandler::openOk ( const framing::Array& knownBrokers )
for ( i = knownBrokers.begin(); i != knownBrokers.end(); ++i )
knownBrokersUrls.push_back(Url((*i)->get<std::string>()));
setState(OPEN);
+ QPID_LOG(info, "Known-brokers for connection: " << log::formatList(knownBrokersUrls));
}
diff --git a/cpp/src/qpid/client/FailoverListener.cpp b/cpp/src/qpid/client/FailoverListener.cpp
index 3254686d9c..5ca617138c 100644
--- a/cpp/src/qpid/client/FailoverListener.cpp
+++ b/cpp/src/qpid/client/FailoverListener.cpp
@@ -21,6 +21,8 @@
#include "FailoverListener.h"
#include "SessionBase_0_10Access.h"
#include "qpid/client/SubscriptionManager.h"
+#include "qpid/log/Statement.h"
+#include "qpid/log/Helpers.h"
namespace qpid {
namespace client {
@@ -67,16 +69,17 @@ FailoverListener::~FailoverListener() {
void FailoverListener::received(Message& msg) {
sys::Mutex::ScopedLock l(lock);
- knowBrokers.clear();
+ knownBrokers.clear();
framing::Array urlArray;
msg.getHeaders().getArray("amq.failover", urlArray);
for (framing::Array::ValueVector::const_iterator i = urlArray.begin(); i < urlArray.end(); ++i )
- knowBrokers.push_back(Url((*i)->get<std::string>()));
+ knownBrokers.push_back(Url((*i)->get<std::string>()));
+ QPID_LOG(info, "Known-brokers update: " << log::formatList(knownBrokers));
}
std::vector<Url> FailoverListener::getKnownBrokers() const {
sys::Mutex::ScopedLock l(lock);
- return knowBrokers;
+ return knownBrokers;
}
}} // namespace qpid::client
diff --git a/cpp/src/qpid/client/FailoverListener.h b/cpp/src/qpid/client/FailoverListener.h
index 39bea90bb3..c702fed846 100644
--- a/cpp/src/qpid/client/FailoverListener.h
+++ b/cpp/src/qpid/client/FailoverListener.h
@@ -50,7 +50,7 @@ class FailoverListener : public MessageListener {
mutable sys::Mutex lock;
std::auto_ptr<SubscriptionManager> subscriptions;
sys::Thread thread;
- std::vector<Url> knowBrokers;
+ std::vector<Url> knownBrokers;
};
}} // namespace qpid::client