package main
import (
	"context"
	"fmt"
	"github.com/redis/go-redis/v9"
	"time"
)

var ctx = context.Background()
func main() {
	rdb := redis.NewClient(&redis.Options{
		Addr:     "localhost:6379",
		Password: "", // no password set
		DB:       0,  // use default DB
	})
	pubsub := rdb.Subscribe(ctx, "mychannel1", "-10000")
	// Go channel which receives messages.
	ch := pubsub.Channel()

	// Publish a message.
	rdb.Publish(ctx, "mychannel1", "hello")
	rdb.Publish(ctx, "mychannel1", "test qaq")
	rdb.Publish(ctx, "-10000", "996")

	time.AfterFunc(time.Second, func() {
		// When pubsub is closed channel is closed too.
		_ = pubsub.Close()
	})

	// Consume messages.
	for msg := range ch {
		fmt.Println(msg.Channel, msg.Payload)
	}

}