Addded a test for creating a channel when the connection is closed.

celery · Sep 11, 2019 · 115285c · 115285c
1 parent a797885
commit 115285c
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/t/unit/test_connection.py b/t/unit/test_connection.py
@@ -357,6 +357,12 @@ def test_channel(self):
         c2 = self.conn.channel(3, callback)
         assert c2 is c
 
+    def test_channel_when_connection_is_closed(self):
+        self.conn.collect()
+        callback = Mock(name='callback')
+        with pytest.raises(RecoverableConnectionError):
+            self.conn.channel(3, callback)
+
     def test_is_alive(self):
         with pytest.raises(NotImplementedError):
             self.conn.is_alive()