|
@@ -43,7 +43,11 @@ func (s *Application) start(ctx context.Context) (err error) {
|
|
|
if s.conf.Http {
|
|
|
restServ := rest_http.New(s, s.conf.Core, s.conf.GetHTTPHeaders()())
|
|
|
restServ.Prepare(server, s.conf.GetHttpPrefix())
|
|
|
- //log.Println("http part prepared...")
|
|
|
+ if s.conf.HttpHandlers != nil {
|
|
|
+ for prefix, handler := range s.conf.HttpHandlers {
|
|
|
+ server.HandleFunc(prefix, handler)
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|
|
|
if s.conf.Websocket {
|
|
|
s.chConnect = make(chan rest.IStream)
|
|
@@ -51,7 +55,6 @@ func (s *Application) start(ctx context.Context) (err error) {
|
|
|
ws.Prepare(server, s.conf.GetWebsocketPrefix())
|
|
|
s.Sockets = NewSockets()
|
|
|
go s.work()
|
|
|
- //log.Println("websocket engine prepared...")
|
|
|
}
|
|
|
if err = server.Listen(time.Second, s.ctx); err != nil {
|
|
|
s.cancel()
|