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 2018-03-21 19:56:34 +09:00
parent 9c9b7882be
commit de5f6de361
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
redis/subscribers.go
View File

@ -2,7 +2,6 @@ package redis
import ( import (
"encoding/json" "encoding/json"
"fmt"
"sync" "sync"
"git.loafle.net/commons_go/logging" "git.loafle.net/commons_go/logging"
@ -127,7 +126,7 @@ func listenSubscriptions(s *subscribers) {
case redis.Message: case redis.Message:
if h, ok := s.subHandlers[v.Channel]; ok { if h, ok := s.subHandlers[v.Channel]; ok {
if message, err := unmarshalMessage(v.Data); nil != err { if message, err := unmarshalMessage(v.Data); nil != err {
logging.Logger().Error(fmt.Sprintf("Subscriber Unmarshal error:%v", err)) logging.Logger().Errorf("Subscriber Unmarshal error:%v", err)
break break
} else { } else {
h.OnSubscribe(v.Channel, message) h.OnSubscribe(v.Channel, message)