From 15ef9f393dc1354911f6d5af3c4558dd8096e136 Mon Sep 17 00:00:00 2001 From: "Carl C. Trieloff" Date: Wed, 15 Aug 2007 19:16:46 +0000 Subject: - async message fix in dequeue - addition of test for async enqueue of messages on BrokerQueue git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@566306 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/src/tests/QueueTest.cpp | 25 +++++++++++++++++++++++++ 1 file changed, 25 insertions(+) (limited to 'qpid/cpp/src/tests') diff --git a/qpid/cpp/src/tests/QueueTest.cpp b/qpid/cpp/src/tests/QueueTest.cpp index fad2702f38..6b30f9ff42 100644 --- a/qpid/cpp/src/tests/QueueTest.cpp +++ b/qpid/cpp/src/tests/QueueTest.cpp @@ -63,6 +63,7 @@ class QueueTest : public CppUnit::TestCase CPPUNIT_TEST(testRegistry); CPPUNIT_TEST(testDequeue); CPPUNIT_TEST(testBound); + CPPUNIT_TEST(testAsyncMessage); CPPUNIT_TEST_SUITE_END(); @@ -72,6 +73,30 @@ class QueueTest : public CppUnit::TestCase new BasicMessage(0, exchange, routingKey, false, false)); } + + void testAsyncMessage(){ + + Queue::shared_ptr queue(new Queue("my_test_queue", true)); + Message::shared_ptr received; + + TestConsumer c1; + queue->consume(&c1); + + + //Test basic delivery: + Message::shared_ptr msg1 = message("e", "A"); + queue->process(msg1); + sleep(2); + + CPPUNIT_ASSERT(!c1.received); + msg1->enqueueComplete(); + + received = queue->dequeue(); + CPPUNIT_ASSERT_EQUAL(msg1.get(), received.get()); + + + } + void testConsumers(){ Queue::shared_ptr queue(new Queue("my_queue", true)); -- cgit v1.2.1