Function subscribe

example/maintnotifiations-pubsub/main.go:149–175

(ctx context.Context, rdb *redis.Client, topic string, subscriberId int, wg *sync.WaitGroup)

}

func subscribe(ctx context.Context, rdb *redis.Client, topic string, subscriberId int, wg *sync.WaitGroup) {
	defer wg.Done()
	rec := rdb.Subscribe(ctx, topic)
	recChan := rec.Channel()
	for {
		select {
		case <-ctx.Done():
			rec.Close()
			return
		default:
			select {
			case <-ctx.Done():
				rec.Close()
				return
			case msg := <-recChan:
				err := rdb.Incr(ctx, "received").Err()
				if err != nil {
					if err.Error() != "context canceled" {
						log.Printf("%s\n", err.Error())
						cntErrors.Add(1)
					}
				}
				_ = msg // Use the message to avoid unused variable warning
			}
		}
	}
}