[Pubsub] handle closed redis channel (#800)

2023-11-15 00:04:34 +00:00 · 2023-11-15 00:04:34 +00:00 · 0793af5f9f
parent 07951e7d7e
commit 0793af5f9f
1 changed files with 5 additions and 1 deletions
--- a/pubsub/redis.go
+++ b/pubsub/redis.go
@ -142,7 +142,11 @@ func (s *redisSubscriber) start(ctx context.Context) {
 		select {
 		case <-ctx.Done():
 			return
-		case msg := <-ch:
+		case msg, ok := <-ch:
+			if !ok {
+				log.Ctx(ctx).Debug().Msg("redis channel was closed")
+				return
+			}
 			if err := s.handler([]byte(msg.Payload)); err != nil {
 				log.Ctx(ctx).Err(err).Msg("received an error from handler function")
 			}