Handle asynchronous enqueue of messages.

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

1 files changed, 2 insertions, 0 deletions

diff --git a/qpid/cpp/src/tests/QueueTest.cpp b/qpid/cpp/src/tests/QueueTest.cpp
index bf742f9511..29f0d17cef 100644
--- a/qpid/cpp/src/tests/QueueTest.cpp
+++ b/qpid/cpp/src/tests/QueueTest.cpp
@@ -91,6 +91,7 @@ class QueueTest : public CppUnit::TestCase
        
         //Test basic delivery:
         Message::shared_ptr msg1 = message("e", "A");
+        msg1->enqueueAsync();//this is done on enqueue which is not called from process
         queue->process(msg1);
 	sleep(2);
 
@@ -107,6 +108,7 @@ class QueueTest : public CppUnit::TestCase
     void testAsyncMessageCount(){
         Queue::shared_ptr queue(new Queue("my_test_queue", true));
         Message::shared_ptr msg1 = message("e", "A");
+        msg1->enqueueAsync();//this is done on enqueue which is not called from process
 	
         queue->process(msg1);
 	sleep(2);