def METHOD_NAME(self):
    conn = ContextMock(name='connection')
    self.c.connection = conn
    conn.connection_errors = (KeyError,)
    conn.channel_errors = ()
    consume = self.c.consume = Mock(name='c.consume')
    with patch('kombu.mixins.warn') as warn:
        def se_raises(*args, **kwargs):
            self.c.should_stop = True
            raise KeyError('foo')
        self.c.should_stop = False
        consume.side_effect = se_raises
        self.c.run()
        warn.assert_called()