common.RedisPubSubCommonTestCase.assertIn

All Samples(16) | Call(16) | Derive(0) | Import(0)

src/z/a/zato-HEAD/code/zato-common/test/zato/common/pubsub/test_api_impl.py zato(Download)

        last_pub_time = self.api.impl.kvdb.hkeys(self.api.impl.LAST_PUB_TIME_KEY)
 
        self.assertIn(str(consumer.id), last_seen_consumer)
        self.assertIn(str(producer.id), last_seen_producer)
        self.assertIn(topic.name, last_pub_time)

 
        for topic in topics:
            self.assertIn(client_id, self.api.impl.topic_to_cons[topic])
 
# ################################################################################################################################

        self.api.add_topic(topic)
 
        self.assertIn(name, self.api.impl.topics)
        self.assertEquals(len(self.api.impl.topics), 1)

src/z/a/zato-HEAD/code/zato-common/test/zato/common/pubsub/test_full_path.py zato(Download)

 
        for msg_id in expected_msg_ids:
            self.assertIn(msg_id, msgs_metadata)
 
        if before_last_acknowledge:

 
        for key in expected_keys:
            self.assertIn(key, keys)
 
        # Check values of messages published

        eq_(len(keys), 9)
 
        self.assertIn(ps.UNACK_COUNTER_KEY, keys)
        self.assertIn(ps.MSG_VALUES_KEY, keys)
 
        for sub_key in(sub_key_crm, sub_key_billing, sub_key_erp):
            key = ps.CONSUMER_MSG_IDS_PREFIX.format(sub_key)
            self.assertIn(key, keys)