3
0

Replace panic on feedSessions() error with log

This commit is contained in:
Denis Arh
2018-09-24 20:03:35 +02:00
parent a7431fd8aa
commit 59d8856d30
+5 -3
View File
@@ -2,7 +2,7 @@ package websocket
import (
"context"
"fmt"
"log"
"github.com/go-chi/chi"
@@ -14,8 +14,10 @@ func MountRoutes(ctx context.Context, config *repository.Flags) func(chi.Router)
events := repository.NewEvents(ctx)
go func() {
if err := eq.feedSessions(ctx, config, events, store); err != nil {
panic(fmt.Sprintf("Error when starting sessions event feed: %+v", err))
for {
if err := eq.feedSessions(ctx, config, events, store); err != nil {
log.Printf("Error when starting sessions event feed: %+v", err)
}
}
}()
eq.store(ctx, events)