test: add consumer.close

This commit is contained in:
plum-lihui 2023-07-03 14:42:04 +08:00
parent 33e52c3dbe
commit 98fc222797
1 changed files with 4 additions and 4 deletions

View File

@ -122,18 +122,18 @@ class TDTestCase:
tdLog.info("consumer.subscribe() fail ") tdLog.info("consumer.subscribe() fail ")
tdLog.info("%s"%(e)) tdLog.info("%s"%(e))
if (expectResult == "fail"): if (expectResult == "fail"):
consumer.close consumer.close()
return 'success' return 'success'
else: else:
consumer.close consumer.close()
return 'fail' return 'fail'
tdLog.info("consumer.subscribe() success ") tdLog.info("consumer.subscribe() success ")
if (expectResult == "success"): if (expectResult == "success"):
consumer.close consumer.close()
return 'success' return 'success'
else: else:
consumer.close consumer.close()
return 'fail' return 'fail'
def tmqCase1(self): def tmqCase1(self):