As I say, when the mq is stopped, something happened like that it will throw loop exception. I think bug is on that place. ``` // force disconnect, if previous established connection exists $this->disconnect(); ``` It cannot write to the socket.