1 files changed, 3 insertions, 1 deletions
diff --git a/qpid/cpp/src/qpid/sys/AsynchIOHandler.cpp b/qpid/cpp/src/qpid/sys/AsynchIOHandler.cpp
index 35b75c1fe8..3bc05e4bf9 100644
--- a/qpid/cpp/src/qpid/sys/AsynchIOHandler.cpp
+++ b/qpid/cpp/src/qpid/sys/AsynchIOHandler.cpp
@@ -145,8 +145,10 @@ bool AsynchIOHandler::readbuff(AsynchIO& , AsynchIO::BufferBase* buff) {
             // Lock and retest credit to make sure we don't race with increasing credit
             ScopedLock<Mutex> l(creditLock);
             assert(readCredit.get() >= 0);
-            if (readCredit.get() == 0)
+            if (readCredit.get() == 0) {
+                aio->stopReading();
                 return false;
+            }
         }
     }
     return true;