'If the underlying producer raises an exception when resumeProducing is
called, the streaming wrapper should log the error, unregister from
the consumer and stop streaming.'

def test_resumeProducingRaises(self):

    consumer = StringTransport()
    done = self.resumeProducingRaises(consumer, [(ZeroDivisionError, 'failed,    producing    will    be    stopped')])
    def cleanShutdown(ignore):
        self.assertIsNone(consumer.producer)
    done.addCallback(cleanShutdown)
    return done
