Как в GO сделать постоянную подписку на канал в Redis?

Question

[riserise]

Всем здравствуйте, собственно сабж

package main

import (
    "fmt"
	"github.com/go-redis/redis"
)

func main() {

	client := redis.NewClient(&redis.Options{
		Addr: "localhost:6379",
		Password: "",
		DB: 0,
	})

        pubsub := client.Subscribe("test")
    	defer pubsub.Close()
    	msg, err := pubsub.ReceiveMessage()
    	if err != nil {
    		panic(err)
    	}
    	fmt.Println(msg.Channel, msg.Payload)
}

Как это дело заставить работать постоянно, а не завершаться после первого же значения помещённого в канал?

Answer 1

[Папа Стифлера]

Использовать pubsub.Channel() и читать из канала в цикле. В документации есть пример.

Comments

[Папа Стифлера]

riserise, создайте issue на github.