From 0e118b7f804489e6896ce7ed4384a9f42f2443bb Mon Sep 17 00:00:00 2001 From: crusader Date: Wed, 27 Sep 2017 16:14:19 +0900 Subject: [PATCH] ing --- redis/subscribers.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/redis/subscribers.go b/redis/subscribers.go index 799b3c8..f00ddaf 100644 --- a/redis/subscribers.go +++ b/redis/subscribers.go @@ -75,7 +75,7 @@ func (s *subscribers) listenSubscriptions() { switch v := s.conn.Receive().(type) { case redis.Message: if h, ok := s.subHandlers[v.Channel]; ok { - h.OnSubscribe(string(v.Data)) + h.OnSubscribe(v.Channel, string(v.Data)) } break case redis.Subscription: