diff --git a/amqpstorm/io.py b/amqpstorm/io.py
index 9a8ed33d..6664e9a3 100644
--- a/amqpstorm/io.py
+++ b/amqpstorm/io.py
@@ -270,6 +270,8 @@ def _receive(self):
         data_in = EMPTY_BUFFER
         try:
             data_in = self._read_from_socket()
+            if len(data_in) == 0:
+                raise socket.error("connection closed by server")
         except socket.timeout:
             pass
         except compatibility.SSLWantReadError: