Merge pull request #946 from vitaly-krugl/is_closed-test

Implemented BlockingConnection test TestLostConnectionResultsInIsClosedConnectionAndChannel

tests/acceptance/blocking_adapter_test.py

@@ -149,6 +149,25 @@ def test(self):
         self.assertTrue(connection.is_closed)
 
 
+class TestLostConnectionResultsInIsClosedConnectionAndChannel(BlockingTestCaseBase):
+    def test(self):
+        connection = self._connect()
+        channel = connection.channel()
+
+        # Simulate the server dropping the socket connection
+        connection._impl.socket.shutdown(socket.SHUT_RDWR)
+
+        with self.assertRaises(pika.exceptions.ConnectionClosed):
+            # Changing QoS should result in ConnectionClosed
+            channel.basic_qos()
+
+        # Now check is_open/is_closed on channel and connection
+        self.assertFalse(channel.is_open)
+        self.assertTrue(channel.is_closed)
+        self.assertFalse(connection.is_open)
+        self.assertTrue(connection.is_closed)
+
+
 class TestInvalidExchangeTypeRaisesConnectionClosed(BlockingTestCaseBase):
     def test(self):
         """BlockingConnection: ConnectionClosed raised when creating exchange with invalid type"""  # pylint: disable=C0301