From 3976dc568f6eb9a28bea14b8363f5b49ff825fdd Mon Sep 17 00:00:00 2001 From: yaziming Date: Tue, 10 Sep 2019 12:55:14 +0800 Subject: [PATCH] fix(all): fix redis subscrible wrong channel fix redis subscrible wrong channel Closes #222 --- backend/database/pubsub.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/backend/database/pubsub.go b/backend/database/pubsub.go index c5fdbda9..8487df11 100644 --- a/backend/database/pubsub.go +++ b/backend/database/pubsub.go @@ -19,7 +19,7 @@ func (r *Redis) Close() { } func (r *Redis) subscribe(ctx context.Context, consume ConsumeFunc, channel ...string) error { psc := redis.PubSubConn{Conn: r.pool.Get()} - if err := psc.Subscribe(redis.Args{}.AddFlat(channel)); err != nil { + if err := psc.Subscribe(redis.Args{}.AddFlat(channel)...); err != nil { return err } done := make(chan error, 1)