overflow_backup_2018_0455/overflow_subscriber
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

ing

Browse Source
This commit is contained in:
crusader 2017-09-27 16:14:19 +09:00
parent e69682ca44
commit 0e118b7f80
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
redis/subscribers.go
View File

@ -75,7 +75,7 @@ func (s *subscribers) listenSubscriptions() {
switch v := s.conn.Receive().(type) { switch v := s.conn.Receive().(type) {
case redis.Message: case redis.Message:
if h, ok := s.subHandlers[v.Channel]; ok { if h, ok := s.subHandlers[v.Channel]; ok {
h.OnSubscribe(string(v.Data)) h.OnSubscribe(v.Channel, string(v.Data))
} }
break break
case redis.Subscription: case redis.Subscription: