- corrected getMessageCount() for async messages

- added test for async message count.



git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@567059 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 16 insertions, 0 deletions

diff --git a/cpp/src/tests/QueueTest.cpp b/cpp/src/tests/QueueTest.cpp
index 6b30f9ff42..e7ca124631 100644
--- a/cpp/src/tests/QueueTest.cpp
+++ b/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));