Author: aconway
Date: Fri Oct 10 09:42:53 2008
New Revision: 703519
URL: http://svn.apache.org/viewvc?rev=703519&view=rev
Log:
Client-side INFO logging for known-broker updates.
Modified:
incubator/qpid/trunk/qpid/cpp/src/qpid/client/ConnectionHandler.cpp
incubator/qpid/trunk/qpid/cpp/src/qpid/client/FailoverListener.cpp
incubator/qpid/trunk/qpid/cpp/src/qpid/client/FailoverListener.h
Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/client/ConnectionHandler.cpp
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/client/ConnectionHandler.cpp?rev=703519&r1=703518&r2=703519&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/client/ConnectionHandler.cpp
(original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/client/ConnectionHandler.cpp Fri Oct
10 09:42:53 2008
@@ -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 @@
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));
}
Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/client/FailoverListener.cpp
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/client/FailoverListener.cpp?rev=703519&r1=703518&r2=703519&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/client/FailoverListener.cpp
(original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/client/FailoverListener.cpp Fri Oct
10 09:42:53 2008
@@ -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 @@
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
Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/client/FailoverListener.h
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/client/FailoverListener.h?rev=703519&r1=703518&r2=703519&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/client/FailoverListener.h (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/client/FailoverListener.h Fri Oct 10
09:42:53 2008
@@ -50,7 +50,7 @@
mutable sys::Mutex lock;
std::auto_ptr<SubscriptionManager> subscriptions;
sys::Thread thread;
- std::vector<Url> knowBrokers;
+ std::vector<Url> knownBrokers;
};
}} // namespace qpid::client
