Did I find the right examples for you? yes no      Crawl my project      Python Jobs

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)