|
@@ -36,7 +36,6 @@ func main() {
|
|
})
|
|
})
|
|
defer s.Stop()
|
|
defer s.Stop()
|
|
fmt.Printf("Starting rpc server at %s...\n", c.ListenOn)
|
|
fmt.Printf("Starting rpc server at %s...\n", c.ListenOn)
|
|
- s.Start()
|
|
|
|
|
|
|
|
if c.Mode != "dev" {
|
|
if c.Mode != "dev" {
|
|
envitem.SetOptions(envitem.Options{GtServerIp: c.GtServerIp, Cache: ctx.Cache})
|
|
envitem.SetOptions(envitem.Options{GtServerIp: c.GtServerIp, Cache: ctx.Cache})
|
|
@@ -53,5 +52,7 @@ func main() {
|
|
}()
|
|
}()
|
|
}
|
|
}
|
|
// 接收识别到的事件, 处理, 目前只有写入队列(暂时只有redis), 写入数据库
|
|
// 接收识别到的事件, 处理, 目前只有写入队列(暂时只有redis), 写入数据库
|
|
- _ = handler.HandlerEventNotify(ctx)
|
|
|
|
|
|
+ go handler.HandlerEventNotify(ctx)
|
|
|
|
+
|
|
|
|
+ s.Start()
|
|
}
|
|
}
|