fix: rocketmq client add start (#89)

sysulq · web-flow · commit 5510727553bf · 2021-07-16T11:14:04.000+08:00
diff --git a/internal/pkg/invoker/invoker.go b/internal/pkg/invoker/invoker.go
@@ -71,7 +71,7 @@ func Init() {
 		mqConfig.DialTimeout = config.DialTimeout
 
 		EventProducer = mqConfig.Build()
-		if err != nil {
+		if err := EventProducer.Start(); err != nil {
 			panic("init junoevnet producer failed. err=" + err.Error())
 		}
 	}

Original file line number	Diff line number	Diff line change
`@@ -71,7 +71,7 @@ func Init() {`
`71`	`71`	`mqConfig.DialTimeout = config.DialTimeout`
`72`	`72`
`73`	`73`	`EventProducer = mqConfig.Build()`
`74`		`- if err != nil {`
	`74`	`+ if err := EventProducer.Start(); err != nil {`
`75`	`75`	`panic("init junoevnet producer failed. err=" + err.Error())`
`76`	`76`	`}`
`77`	`77`	`}`