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:38:43 +09:00
parent 20ad490e27
commit 9a532bb137
3 changed files with 3 additions and 3 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(v.Channel, string(v.Data)) h.OnSubscribe(v.Channel, v.Data)
} }
break break
case redis.Subscription: case redis.Subscription:

2
subscriber_handler.go
View File

@ -2,5 +2,5 @@ package overflow_subscriber
type SubscriberHandler interface { type SubscriberHandler interface {
GetChannel() string GetChannel() string
OnSubscribe(channel string, payload string) OnSubscribe(channel string, payload []byte)
} }

2
subscriber_handlers.go
View File

@ -7,5 +7,5 @@ type SubscriberHandlers struct {
func (h *SubscriberHandlers) GetChannel() string { func (h *SubscriberHandlers) GetChannel() string {
return h.Channel return h.Channel
} }
func (h *SubscriberHandlers) OnSubscribe(channel string, payload string) { func (h *SubscriberHandlers) OnSubscribe(channel string, payload []byte) {
} }