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 | 4aad013bdb4fcac090a31d20b333345865a32309 (patch) | |
tree | d95fa97a418ed096b33d093ca23a4be1dc6f86fb /cpp/src/tests/QueueTest.cpp | |
parent | 392cd6f2b17e51631dde930668d437356430ab82 (diff) | |
download | qpid-python-4aad013bdb4fcac090a31d20b333345865a32309.tar.gz |
Remove optimistic consume options. Better default message for SSL errors.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@718277 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/QueueTest.cpp')
-rw-r--r-- | cpp/src/tests/QueueTest.cpp | 32 |
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; |