add test

2021-02-01 15:42:46 +08:00
parent 3ad4c76acd
commit bd2a379d17
1 changed files with 3 additions and 0 deletions
@@ -40,6 +40,9 @@ func test() {
 	if err != nil {
 		println("create database error ", err)
 	}
+
+	utils.CreateProducer(pulsarUrl, topic, name)
+	utils.ClosePulsar()
 }

 func init() {