summaryrefslogtreecommitdiff
path: root/qpid/cpp/include
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2010-07-01 19:19:48 +0000
committerAlan Conway <aconway@apache.org>2010-07-01 19:19:48 +0000
commit61847068238af35543de06e54bc757dbfb3da776 (patch)
treebd850b91b8af5acb7722ecad24beb943a8a5f186 /qpid/cpp/include
parente570224156a2ee843026bea97a5128389a962d8b (diff)
downloadqpid-python-61847068238af35543de06e54bc757dbfb3da776.tar.gz
Fix spordic failure in cluster_test testConnectionKnownHosts.
Very occasional failure of the form: cluster_test.cpp(547): error in "testConnectionKnownHosts": check kb0 == kb2 failed [42179 57640 != 44199 57640 ] ]) Fix is to avoid using possibly out-of-date initial-brokers data from the connection. Only rely on updates received from the amq.failover exchange. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@959751 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/include')
-rw-r--r--qpid/cpp/include/qpid/client/FailoverListener.h9
1 files changed, 8 insertions, 1 deletions
diff --git a/qpid/cpp/include/qpid/client/FailoverListener.h b/qpid/cpp/include/qpid/client/FailoverListener.h
index 8414b80f2b..59108eb7cb 100644
--- a/qpid/cpp/include/qpid/client/FailoverListener.h
+++ b/qpid/cpp/include/qpid/client/FailoverListener.h
@@ -60,6 +60,12 @@ class FailoverListener : private MessageListener, private qpid::sys::Runnable
/** Subscribe to amq.failover exchange. */
QPID_CLIENT_EXTERN FailoverListener(Connection);
+ /** Subscribe to amq.failover exchange.
+ *@param useInitial If true use the connection's initial brokers as
+ * the initial value of getKnownBrokers
+ */
+ QPID_CLIENT_EXTERN FailoverListener(Connection, bool useInitial);
+
QPID_CLIENT_EXTERN ~FailoverListener();
/** Returns the latest list of known broker URLs. */
@@ -68,7 +74,8 @@ class FailoverListener : private MessageListener, private qpid::sys::Runnable
private:
void received(Message& msg);
void run();
-
+ void init(bool);
+
mutable sys::Mutex lock;
Connection connection;
Session session;