summaryrefslogtreecommitdiff
path: root/cpp/src/tests
diff options
context:
space:
mode:
authorKenneth Anthony Giusti <kgiusti@apache.org>2011-03-08 15:04:07 +0000
committerKenneth Anthony Giusti <kgiusti@apache.org>2011-03-08 15:04:07 +0000
commit94d67ed2b72e56a60989bc7393efc6a0b6b812c3 (patch)
tree6fde43aae1e56f99b191166d2872d6e1608fe1b1 /cpp/src/tests
parent362d91dd7261b21863f84cd6364d059c25ceeedb (diff)
downloadqpid-python-94d67ed2b72e56a60989bc7393efc6a0b6b812c3.tar.gz
QPID-3073: refactor to eliminate locks, malloc, and map insert/remove in receive path.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1079385 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests')
-rw-r--r--cpp/src/tests/MessageUtils.h14
-rw-r--r--cpp/src/tests/QueueTest.cpp2
2 files changed, 0 insertions, 16 deletions
diff --git a/cpp/src/tests/MessageUtils.h b/cpp/src/tests/MessageUtils.h
index baca14cf4e..a1b140d484 100644
--- a/cpp/src/tests/MessageUtils.h
+++ b/cpp/src/tests/MessageUtils.h
@@ -20,7 +20,6 @@
*/
#include "qpid/broker/Message.h"
-#include "qpid/broker/AsyncCompletion.h"
#include "qpid/framing/AMQFrame.h"
#include "qpid/framing/MessageTransferBody.h"
#include "qpid/framing/Uuid.h"
@@ -29,17 +28,6 @@ using namespace qpid;
using namespace broker;
using namespace framing;
-namespace {
- class DummyCompletion : public AsyncCompletion
- {
- public:
- DummyCompletion() {}
- virtual ~DummyCompletion() {}
- protected:
- void completed(bool) {}
- };
-}
-
namespace qpid {
namespace tests {
@@ -62,8 +50,6 @@ struct MessageUtils
msg->getFrames().getHeaders()->get<DeliveryProperties>(true)->setRoutingKey(routingKey);
if (durable)
msg->getFrames().getHeaders()->get<DeliveryProperties>(true)->setDeliveryMode(2);
- boost::shared_ptr<AsyncCompletion>dc(new DummyCompletion());
- msg->setIngressCompletion(dc);
return msg;
}
diff --git a/cpp/src/tests/QueueTest.cpp b/cpp/src/tests/QueueTest.cpp
index fd30a98ac0..2059727e7b 100644
--- a/cpp/src/tests/QueueTest.cpp
+++ b/cpp/src/tests/QueueTest.cpp
@@ -88,8 +88,6 @@ intrusive_ptr<Message> create_message(std::string exchange, std::string routingK
msg->getFrames().append(method);
msg->getFrames().append(header);
msg->getFrames().getHeaders()->get<DeliveryProperties>(true)->setRoutingKey(routingKey);
- boost::shared_ptr<AsyncCompletion>dc(new DummyCompletion());
- msg->setIngressCompletion(dc);
return msg;
}