|
@@ -49,6 +49,7 @@ func (s *Application) start(ctx context.Context) (err error) {
|
|
|
s.chConnect = make(chan rest.IStream)
|
|
s.chConnect = make(chan rest.IStream)
|
|
|
ws := rest_websocket.New(s, s.conf.Core)
|
|
ws := rest_websocket.New(s, s.conf.Core)
|
|
|
ws.Prepare(server, s.conf.GetWebsocketPrefix())
|
|
ws.Prepare(server, s.conf.GetWebsocketPrefix())
|
|
|
|
|
+ s.Sockets = NewSockets()
|
|
|
go s.work()
|
|
go s.work()
|
|
|
//log.Println("websocket engine prepared...")
|
|
//log.Println("websocket engine prepared...")
|
|
|
}
|
|
}
|
