diff options
Diffstat (limited to 'cpp/src/tests/XmlClientSessionTest.cpp')
-rw-r--r-- | cpp/src/tests/XmlClientSessionTest.cpp | 26 |
1 files changed, 1 insertions, 25 deletions
diff --git a/cpp/src/tests/XmlClientSessionTest.cpp b/cpp/src/tests/XmlClientSessionTest.cpp index 534ecf70f2..98558f0a76 100644 --- a/cpp/src/tests/XmlClientSessionTest.cpp +++ b/cpp/src/tests/XmlClientSessionTest.cpp @@ -29,7 +29,7 @@ #include "qpid/framing/TransferContent.h" #include "qpid/framing/reply_exceptions.h" #include "qpid/client/Connection.h" -#include "qpid/client/Dispatcher.h" +#include "qpid/client/SubscriptionManager.h" #include "qpid/client/LocalQueue.h" #include "qpid/client/Session.h" #include "qpid/client/SubscriptionManager.h" @@ -54,30 +54,6 @@ using std::endl; Shlib shlib("../.libs/xml.so"); -struct DummyListener : public sys::Runnable, public MessageListener { - std::vector<Message> messages; - string name; - uint expected; - Dispatcher dispatcher; - - DummyListener(Session& session, const string& n, uint ex) : - name(n), expected(ex), dispatcher(session) {} - - void run() - { - dispatcher.listen(name, this); - dispatcher.run(); - } - - void received(Message& msg) - { - messages.push_back(msg); - if (--expected == 0) - dispatcher.stop(); - } -}; - - class SubscribedLocalQueue : public LocalQueue { private: SubscriptionManager& subscriptions; |