Process messages until channel close on shutdown
- Remove Shutdown check - process all messages in buffer
This commit is contained in:
@@ -69,9 +69,7 @@ func main() {
|
|||||||
log.Info("Aleesa-misc-go started")
|
log.Info("Aleesa-misc-go started")
|
||||||
|
|
||||||
for msg := range ch {
|
for msg := range ch {
|
||||||
if !misc.Shutdown {
|
misc.MsgParser(misc.Ctx, msg.Payload)
|
||||||
misc.MsgParser(misc.Ctx, msg.Payload)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -17,9 +17,6 @@ var ForwardMax int64 = 5
|
|||||||
var RedisClient *redis.Client
|
var RedisClient *redis.Client
|
||||||
var Subscriber *redis.PubSub
|
var Subscriber *redis.PubSub
|
||||||
|
|
||||||
// Ставится в true, если мы получили сигнал на выключение.
|
|
||||||
var Shutdown = false
|
|
||||||
|
|
||||||
// Канал, в который приходят уведомления для хэндлера сигналов от траппера сигналов.
|
// Канал, в который приходят уведомления для хэндлера сигналов от траппера сигналов.
|
||||||
var SigChan = make(chan os.Signal, 1)
|
var SigChan = make(chan os.Signal, 1)
|
||||||
|
|
||||||
|
|||||||
@@ -28,9 +28,6 @@ func SigHandler() {
|
|||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
// Чтобы не срать в логи ошибками от редиски, проставим shutdown state приложения в true.
|
|
||||||
Shutdown = true
|
|
||||||
|
|
||||||
// Отпишемся от всех каналов и закроем коннект к редиске.
|
// Отпишемся от всех каналов и закроем коннект к редиске.
|
||||||
if err = Subscriber.Unsubscribe(Ctx); err != nil {
|
if err = Subscriber.Unsubscribe(Ctx); err != nil {
|
||||||
log.Errorf("Unable to unsubscribe from redis channels cleanly: %s", err)
|
log.Errorf("Unable to unsubscribe from redis channels cleanly: %s", err)
|
||||||
|
|||||||
Reference in New Issue
Block a user