1 files changed, 6 insertions, 1 deletions
diff --git a/cpp/src/qpid/amqp/Sasl.cpp b/cpp/src/qpid/amqp/Sasl.cpp
index 7b0779fe94..a7c2eea35b 100644
--- a/cpp/src/qpid/amqp/Sasl.cpp
+++ b/cpp/src/qpid/amqp/Sasl.cpp
@@ -59,7 +59,7 @@ void Sasl::endFrame(void* frame)
 std::size_t Sasl::read(const char* data, size_t available)
 {
     size_t consumed = 0;
-    while (available - consumed > 4/*framesize*/) {
+    while (!stopReading() && available - consumed > 4/*framesize*/) {
         Decoder decoder(data+consumed, available-consumed);
         //read frame-header
         uint32_t frameSize = decoder.readUInt();
@@ -133,4 +133,9 @@ std::size_t Sasl::writeProtocolHeader(char* buffer, std::size_t size)
     }
 }
 
+bool Sasl::stopReading()
+{
+    return false;
+}
+
 }} // namespace qpid::amqp