diff --git a/lib/connection/netio.rb b/lib/connection/netio.rb
index c0df493..602767d 100644
--- a/lib/connection/netio.rb
+++ b/lib/connection/netio.rb
@@ -277,8 +277,8 @@ def _transmit(used_socket, command, headers = {}, body = '')
             end
           end
           used_socket.write "\0"
-          # used_socket.flush if autoflush
-          used_socket.flush
+          used_socket.flush if @autoflush
+          # used_socket.flush
 
           if @protocol >= Stomp::SPL_11
             @ls = Time.now.to_f if @hbs