rabbitmq.go

@@ -28,13 +28,9 @@ type Config struct {
 }
 
 // InitRabbitmq @Title 初始化rabbitmq
-func InitRabbitmq(config Config) error {
+func InitRabbitmq(config Config) (err error) {
 	Rabbitmq.config = config
-	err := getConn()
-	if err != nil && Rabbitmq.config.ReConn {
-		go reConn()
-	}
-	return err
+	return getConn()
 }
 
 // @Title 获取连接