1 files changed, 1 insertions, 9 deletions
diff --git a/cpp/src/qpid/broker/PersistableMessage.cpp b/cpp/src/qpid/broker/PersistableMessage.cpp
index 303a0501f4..76e9404b5d 100644
--- a/cpp/src/qpid/broker/PersistableMessage.cpp
+++ b/cpp/src/qpid/broker/PersistableMessage.cpp
@@ -83,16 +83,8 @@ void PersistableMessage::enqueueComplete() {
             }
         }
     }
-    if (notify) {
+    if (notify) 
         allEnqueuesComplete();
-        sys::ScopedLock<sys::Mutex> l(storeLock);
-        if (store) {
-            for (syncList::iterator i = synclist.begin(); i != synclist.end(); ++i) {
-                PersistableQueue::shared_ptr q(i->lock());
-                if (q) q->notifyDurableIOComplete();
-            } 
-        }            
-    }
 }
 
 bool PersistableMessage::isStoredOnQueue(PersistableQueue::shared_ptr queue){