启用 消息通知

@@ -7,6 +7,7 @@ import (
 	serviceTask "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/node_task"
 	serviceTask "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/node_task"
 	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/log"
 	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/log"
 	_ "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/port/beego"
 	_ "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/port/beego"
+	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/port/consumer"
 )
 )
 
 
 func main() {
 func main() {
@@ -17,7 +18,7 @@ func main() {
 	// for k, v := range methods {
 	// for k, v := range methods {
 	// 	fmt.Printf("%s => %v \n", k, v)
 	// 	fmt.Printf("%s => %v \n", k, v)
 	// }
 	// }
-	// go consumer.Run()
+	go consumer.Run()
 	web.Run()
 	web.Run()
 }
 }