summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/tests/Cluster.h
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2007-10-29 21:14:44 +0000
committerAlan Conway <aconway@apache.org>2007-10-29 21:14:44 +0000
commitb29d9eea42c217b457bb298bad390415ecf5eeff (patch)
treed6e5fed83b962eef780f3aa73509590b6ac66a17 /qpid/cpp/src/tests/Cluster.h
parent36b42cd7921cae46f99cc6bf1c83f2ddacf21395 (diff)
downloadqpid-python-b29d9eea42c217b457bb298bad390415ecf5eeff.tar.gz
client/BlockingQueue.h, sys/ConcurrentQueue.h: merged to sys/BlockingQueue.h
- updated all users qpid/Exception.h: Removed unimplemented clone() function. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@589857 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/tests/Cluster.h')
-rw-r--r--qpid/cpp/src/tests/Cluster.h6
1 files changed, 2 insertions, 4 deletions
diff --git a/qpid/cpp/src/tests/Cluster.h b/qpid/cpp/src/tests/Cluster.h
index d14d7c1392..6ff5c21fdb 100644
--- a/qpid/cpp/src/tests/Cluster.h
+++ b/qpid/cpp/src/tests/Cluster.h
@@ -20,7 +20,7 @@
*/
#include "qpid/cluster/Cluster.h"
-#include "qpid/sys/ConcurrentQueue.h"
+#include "qpid/sys/BlockingQueue.h"
#include "qpid/framing/AMQFrame.h"
#include <boost/bind.hpp>
@@ -45,12 +45,10 @@ using namespace boost;
void null_deleter(void*) {}
template <class T>
-class TestHandler : public Handler<T&>, public ConcurrentQueue<T>
+class TestHandler : public Handler<T&>, public BlockingQueue<T>
{
public:
void handle(T& frame) { push(frame); }
- bool waitPop(T& x) { return waitPop(x, TIME_SEC); }
- using ConcurrentQueue<T>::waitPop;
};
typedef TestHandler<AMQFrame> TestFrameHandler;