消息中心修改

@@ -35,7 +35,7 @@ func init() {
 	log.Info(fmt.Sprintf("init redis:%v", redisSource))
 	log.Info(fmt.Sprintf("init redis:%v", redisSource))
 	if err != nil {
 	if err != nil {
 		log.Fatal("connect to redis error address:", beego.AppConfig.String("redis_add_port"), beego.AppConfig.String("redis_auth"), err)
 		log.Fatal("connect to redis error address:", beego.AppConfig.String("redis_add_port"), beego.AppConfig.String("redis_auth"), err)
-		//panic(err)
+		panic(err)
 	}
 	}
 	dataSource := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?loc=Asia%%2FShanghai&charset=utf8mb4",
 	dataSource := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?loc=Asia%%2FShanghai&charset=utf8mb4",
 		beego.AppConfig.String("mysql_user"),
 		beego.AppConfig.String("mysql_user"),