diff options
| author | Alan Conway <aconway@apache.org> | 2008-11-17 17:03:43 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2008-11-17 17:03:43 +0000 |
| commit | d0d0b1c7b42a5fbbf7c3cb2196ed34f565d0063c (patch) | |
| tree | 12b75b97cef290388e425dbbb964ba38a7d3f752 /qpid/cpp/src/tests/QueueTest.cpp | |
| parent | cba82b4f3474b00e8e4ab1c74a7cbebac25ad533 (diff) | |
| download | qpid-python-d0d0b1c7b42a5fbbf7c3cb2196ed34f565d0063c.tar.gz | |
Remove optimistic consume options. Better default message for SSL errors.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@718277 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/tests/QueueTest.cpp')
| -rw-r--r-- | qpid/cpp/src/tests/QueueTest.cpp | 32 |
1 files changed, 0 insertions, 32 deletions
diff --git a/qpid/cpp/src/tests/QueueTest.cpp b/qpid/cpp/src/tests/QueueTest.cpp index e854510eba..80ea05c073 100644 --- a/qpid/cpp/src/tests/QueueTest.cpp +++ b/qpid/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; |
