diff --git a/src/qamqpframe.cpp b/src/qamqpframe.cpp
index b7c9ae2..2c4bf10 100644
--- a/src/qamqpframe.cpp
+++ b/src/qamqpframe.cpp
@@ -73,6 +73,13 @@ QDataStream &operator<<(QDataStream &stream, const QAmqpFrame &frame)
 
     // write end
     stream << qint8(QAmqpFrame::FRAME_END);
+    
+    int writeTimeout = QAmqpFrame::writeTimeout();
+    if(writeTimeout >= -1)
+    {
+        stream.device()->waitForBytesWritten(writeTimeout);
+    }
+
     return stream;
 }