ing

2018-04-13 20:03:36 +09:00 · 2018-04-13 20:03:36 +09:00 · a8273a816c
commit a8273a816c
parent 07a8f2726d
1 changed files with 4 additions and 0 deletions
--- a/subscribe/redis/redis.go
+++ b/subscribe/redis/redis.go
@ -118,6 +118,10 @@ func (s *Subscribers) handleSubscriber() {
 					logging.Logger().Errorf("Subscriber: Cannot unmarshal data[%s] of Channel[%s] %v", string(v.Data), v.Channel, err)
 					break
 				}
+				if nil == message.Message {
+					logging.Logger().Errorf("Subscriber: Message is not valid data[%s] of Channel[%s]", string(v.Data), v.Channel)
+					break
+				}
 				msgChan <- message
 			case redis.Subscription:
 			case error: