|
|
@ -14,6 +14,7 @@ func main() {
|
|
|
|
var wg sync.WaitGroup
|
|
|
|
var wg sync.WaitGroup
|
|
|
|
wg.Add(1)
|
|
|
|
wg.Add(1)
|
|
|
|
prometheusPort := flag.Int("prometheus_port", config.Config.Prometheus.MessageTransferPrometheusPort[0], "MessageTransferPrometheusPort default listen port")
|
|
|
|
prometheusPort := flag.Int("prometheus_port", config.Config.Prometheus.MessageTransferPrometheusPort[0], "MessageTransferPrometheusPort default listen port")
|
|
|
|
|
|
|
|
flag.Parse()
|
|
|
|
log.NewPrivateLog(constant.LogFileName)
|
|
|
|
log.NewPrivateLog(constant.LogFileName)
|
|
|
|
logic.Init()
|
|
|
|
logic.Init()
|
|
|
|
fmt.Println("start msg_transfer server")
|
|
|
|
fmt.Println("start msg_transfer server")
|
|
|
|