From 20a9feffbda0d414726f426cc5c550eeb856928a Mon Sep 17 00:00:00 2001 From: "Carl C. Trieloff" Date: Fri, 17 Aug 2007 14:51:24 +0000 Subject: - corrected getMessageCount() for async messages - added test for async message count. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@567059 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/src/tests/QueueTest.cpp | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) (limited to 'qpid/cpp/src/tests/QueueTest.cpp') diff --git a/qpid/cpp/src/tests/QueueTest.cpp b/qpid/cpp/src/tests/QueueTest.cpp index 6b30f9ff42..e7ca124631 100644 --- a/qpid/cpp/src/tests/QueueTest.cpp +++ b/qpid/cpp/src/tests/QueueTest.cpp @@ -64,6 +64,7 @@ class QueueTest : public CppUnit::TestCase CPPUNIT_TEST(testDequeue); CPPUNIT_TEST(testBound); CPPUNIT_TEST(testAsyncMessage); + CPPUNIT_TEST(testAsyncMessageCount); CPPUNIT_TEST_SUITE_END(); @@ -97,6 +98,21 @@ class QueueTest : public CppUnit::TestCase } + + void testAsyncMessageCount(){ + Queue::shared_ptr queue(new Queue("my_test_queue", true)); + Message::shared_ptr msg1 = message("e", "A"); + + queue->process(msg1); + sleep(2); + uint32_t compval=0; + CPPUNIT_ASSERT_EQUAL(compval, queue->getMessageCount()); + msg1->enqueueComplete(); + compval=1; + CPPUNIT_ASSERT_EQUAL(compval, queue->getMessageCount()); + + } + void testConsumers(){ Queue::shared_ptr queue(new Queue("my_queue", true)); -- cgit v1.2.1