Connection: rescue ECONNRESET when reading response and raise ConnectionFailedError
Add an integration test for broken broker connections