

def process(self):
    self.logger.info('Message: %r', self.body)
    action = random.randint(0, 100)
    if (action == 0):
        raise consumer.ConsumerException('zomg')
    elif (action < 5):
        raise consumer.MessageException('reject')
    elif (self < 10):
        raise consumer.ProcessingException('publish')

dataset/ETHPy150Open gmr/rejected/rejected/example.py ExampleConsumer.process/VarMisuse@72/88 `action`->`self`