diff --git a/internal/workers/queueUpdater/queue_updater.go b/internal/workers/queueUpdater/queue_updater.go index dbe27ce..bd7c94d 100644 --- a/internal/workers/queueUpdater/queue_updater.go +++ b/internal/workers/queueUpdater/queue_updater.go @@ -4,6 +4,7 @@ import ( "amocrm/internal/models" "amocrm/internal/workers_methods" "context" + "fmt" "encoding/json" "github.com/twmb/franz-go/pkg/kgo" "go.uber.org/zap" @@ -36,13 +37,20 @@ func (wc *QueueUpdater) Start(ctx context.Context) { defer ticker.Stop() for { - select { - case <-ticker.C: - wc.consumeMessages(ctx) + func () { + defer func(){ + if v:=recover();v!=nil{ + fmt.Println("queuer recover",v) + } + }() + select { + case <-ticker.C: + wc.consumeMessages(ctx) - case <-ctx.Done(): - return - } + case <-ctx.Done(): + return + } + }() } }