- flush async IO if present on sync for 0-10

- notify, for ack from sync for 0-10
- use of raw pointer, to avoid recursive fre



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

1 files changed, 3 insertions, 2 deletions

diff --git a/cpp/src/qpid/broker/Queue.cpp b/cpp/src/qpid/broker/Queue.cpp
index 456e055c74..b72cbc5721 100644
--- a/cpp/src/qpid/broker/Queue.cpp
+++ b/cpp/src/qpid/broker/Queue.cpp
@@ -347,7 +347,8 @@ bool Queue::canAutoDelete() const{
 bool Queue::enqueue(TransactionContext* ctxt, Message::shared_ptr msg)
 {
     if (msg->isPersistent() && store) {
-	msg->enqueueAsync(); //increment to async counter -- for message sent to more than one queue
+std::cout << "--------------  enqueue ------------" << std::endl << std::flush;
+        msg->enqueueAsync(this, store); //increment to async counter -- for message sent to more than one queue
         store->enqueue(ctxt, *msg.get(), *this);
 	return true;
     }
@@ -358,7 +359,7 @@ bool Queue::enqueue(TransactionContext* ctxt, Message::shared_ptr msg)
 bool Queue::dequeue(TransactionContext* ctxt, Message::shared_ptr msg)
 {
     if (msg->isPersistent() && store) {
-	msg->dequeueAsync(); //increment to async counter -- for message sent to more than one queue
+        msg->dequeueAsync(this, store); //increment to async counter -- for message sent to more than one queue
         store->dequeue(ctxt, *msg.get(), *this);
 	return true;
     }