assert_equal(parsed_result['arn'], topic_arn3)
matches = [tenant, UID_PREFIX]
assert_true( all([x in parsed_result['owner'] for x in matches]))
+ assert_equal(parsed_result['dest']['persistent_queue'],
+ tenant + ":" + topic_name + '_3')
+
+ # recall CreateTopic and verify the owner and persistent_queue remain same.
+ topic_conf3 = PSTopicS3(conn, topic_name + '_3', zonegroup,
+ endpoint_args=endpoint_args)
+ topic_arn3 = topic_conf3.set_config()
+ assert_equal(topic_arn3,
+ 'arn:aws:sns:' + zonegroup + ':' + tenant + ':' + topic_name + '_3')
+ # get topic 3 via commandline
+ result = admin(
+ ['topic', 'get', '--topic', topic_name + '_3', '--tenant', tenant],
+ get_config_cluster())
+ parsed_result = json.loads(result[0])
+ assert_equal(parsed_result['arn'], topic_arn3)
+ assert_true(all([x in parsed_result['owner'] for x in matches]))
+ assert_equal(parsed_result['dest']['persistent_queue'],
+ tenant + ":" + topic_name + '_3')
# delete topic 3
- _, result = admin(['topic', 'rm', '--topic', topic_name+'_3', '--tenant', tenant], get_config_cluster())
- assert_equal(result, 0)
+ remove_topic(topic_name + '_3', tenant)
# try to get a deleted topic
- _, result = admin(['topic', 'get', '--topic', topic_name+'_3', '--tenant', tenant], get_config_cluster())
+ _, result = get_topic(topic_name + '_3', tenant, allow_failure=True)
print('"topic not found" error is expected')
assert_equal(result, 2)