summaryrefslogtreecommitdiff
path: root/cpp/src/tests/QueueTest.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/tests/QueueTest.cpp')
-rw-r--r--cpp/src/tests/QueueTest.cpp32
1 files changed, 0 insertions, 32 deletions
diff --git a/cpp/src/tests/QueueTest.cpp b/cpp/src/tests/QueueTest.cpp
index e854510eba..80ea05c073 100644
--- a/cpp/src/tests/QueueTest.cpp
+++ b/cpp/src/tests/QueueTest.cpp
@@ -289,38 +289,6 @@ class TestMessageStoreOC : public NullMessageStore
};
-QPID_AUTO_TEST_CASE(testOptimisticConsume){
-
- client::QueueOptions args;
- args.setPersistLastNode();
-
- // set queue mode
-
- TestMessageStoreOC store;
- Queue::shared_ptr queue(new Queue("my-queue", true, &store));
- queue->setLastNodeFailure();
-
- intrusive_ptr<Message> msg1 = create_message("e", "A");
- msg1->forcePersistent();
-
- //change mode
- args.setOptimisticConsume();
- queue->configure(args);
-
- //enqueue 1 message
- queue->deliver(msg1);
-
- TestConsumer::shared_ptr consumer(new TestConsumer());
- queue->consume(consumer);
- queue->dispatch(consumer);
- if (!consumer->received)
- sleep(2);
-
- BOOST_CHECK_EQUAL(msg1.get(), consumer->last.get());
- BOOST_CHECK_EQUAL(uint32_t(0), queue->getMessageCount());
-
-}
-
QPID_AUTO_TEST_CASE(testLVQOrdering){
client::QueueOptions args;