'BlockingConnection: connection context manager closes connection'

def test(self):

    with self._connect() as connection:
        self.assertIsInstance(connection, pika.BlockingConnection)
        self.assertTrue(connection.is_open)
    self.assertTrue(connection.is_closed)
