

def test_sent_to_kafka(self):
    success = {
        'info-test': 'ABC123',
        'appid': 'someapp',
    }
    message_count = 0
    for message in self.consumer.get_messages():
        if (message is None):
            break
        else:
            the_dict = json.loads(message.message.value)
            self.assertEquals(success, the_dict)
            message_count += 1
    message_count.assertEquals(message_count, 1)

dataset/ETHPy150Open istresearch/scrapy-cluster/redis-monitor/tests/tests_online.py TestRedisMonitor.test_sent_to_kafka/VarMisuse@87/118 `self`->`message_count`