From 59d8856d3025e89fc20191c02693ec610f76278a Mon Sep 17 00:00:00 2001 From: Denis Arh Date: Mon, 24 Sep 2018 20:03:35 +0200 Subject: [PATCH] Replace panic on feedSessions() error with log --- sam/websocket/router.go | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/sam/websocket/router.go b/sam/websocket/router.go index 27da6d3e6..f44f3dbb7 100644 --- a/sam/websocket/router.go +++ b/sam/websocket/router.go @@ -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)