chore: check stop channel close

Signed-off-by: Bo-Yi Wu <[email protected]>

Author: appleboy

redis.go

@@ -265,6 +265,12 @@ func (s *Worker) Run() error {
 	for {
 		select {
 		case m, ok := <-ch:
+			select {
+			case <-s.stop:
+				return nil
+			default:
+			}
+
 			if !ok {
 				return fmt.Errorf("redis pubsub: channel=%s closed", s.channel)
 			}