What steps will reproduce the problem?
1. Publish a message into queue
2.
3.
What is the expected output? What do you see instead?
Expected nothing bad, but an error occurs.
What version of the product are you using? On what operating system?
trunk: Commit:284a578dbd332debc905994e97f45027fd4ab5f0
Please provide any additional information below.
This problem occurs after $this->input->close(); (which is BufferedInput with
same socket) and then fclose($this->sock);
Here is a patch too