You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2013/02/14 21:05:46 UTC
svn commit: r1446313 - in
/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover:
URIPool.cpp URIPool.h
Author: tabish
Date: Thu Feb 14 20:05:46 2013
New Revision: 1446313
URL: http://svn.apache.org/r1446313
Log:
Enhance the API a bit
Modified:
activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.cpp
activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.h
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.cpp?rev=1446313&r1=1446312&r2=1446313&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.cpp Thu Feb 14 20:05:46 2013
@@ -129,3 +129,10 @@ bool URIPool::isPriority(const decaf::ne
return uriPool.getFirst().equals(uri);
}
}
+
+////////////////////////////////////////////////////////////////////////////////
+void URIPool::clear() {
+ synchronized(&uriPool) {
+ this->uriPool.clear();
+ }
+}
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.h?rev=1446313&r1=1446312&r2=1446313&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.h Thu Feb 14 20:05:46 2013
@@ -131,6 +131,11 @@ namespace failover {
*/
bool isPriority(const decaf::net::URI& uri) const;
+ /**
+ * Remove all URIs from the pool.
+ */
+ void clear();
+
};
}}}