From df757e097b9f86b228c51f28e52afc92cf87def3 Mon Sep 17 00:00:00 2001
From: skeris <kotilion.95@gmail.com>
Date: Mon, 2 Dec 2024 22:04:18 +0300
Subject: [PATCH] debug

---
 .../workers/queueUpdater/queue_updater.go     | 20 +++++++++++++------
 1 file changed, 14 insertions(+), 6 deletions(-)

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
+			}
+		}()
 	}
 }