diff --git a/cmd/aleesa-misc-go/main.go b/cmd/aleesa-misc-go/main.go index f730b15..9f53a74 100644 --- a/cmd/aleesa-misc-go/main.go +++ b/cmd/aleesa-misc-go/main.go @@ -69,9 +69,7 @@ func main() { log.Info("Aleesa-misc-go started") for msg := range ch { - if !misc.Shutdown { - misc.MsgParser(misc.Ctx, msg.Payload) - } + misc.MsgParser(misc.Ctx, msg.Payload) } } diff --git a/internal/misc/globals.go b/internal/misc/globals.go index b501de3..605201b 100644 --- a/internal/misc/globals.go +++ b/internal/misc/globals.go @@ -17,9 +17,6 @@ var ForwardMax int64 = 5 var RedisClient *redis.Client var Subscriber *redis.PubSub -// Ставится в true, если мы получили сигнал на выключение. -var Shutdown = false - // Канал, в который приходят уведомления для хэндлера сигналов от траппера сигналов. var SigChan = make(chan os.Signal, 1) diff --git a/internal/misc/sigHandler.go b/internal/misc/sigHandler.go index 884a154..5f21d6e 100644 --- a/internal/misc/sigHandler.go +++ b/internal/misc/sigHandler.go @@ -28,9 +28,6 @@ func SigHandler() { continue } - // Чтобы не срать в логи ошибками от редиски, проставим shutdown state приложения в true. - Shutdown = true - // Отпишемся от всех каналов и закроем коннект к редиске. if err = Subscriber.Unsubscribe(Ctx); err != nil { log.Errorf("Unable to unsubscribe from redis channels cleanly: %s", err)