diff --git a/PhpAmqpLib/Wire/IO/StreamIO.php b/PhpAmqpLib/Wire/IO/StreamIO.php index 68278bcdf..9e3b34453 100644 --- a/PhpAmqpLib/Wire/IO/StreamIO.php +++ b/PhpAmqpLib/Wire/IO/StreamIO.php @@ -353,6 +353,9 @@ public function close() fclose($this->sock); } $this->sock = null; + // Reset last_read and last_write + $this->last_read = null; + $this->last_write = null; } /**