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: