diff --git a/subscribe/redis/redis.go b/subscribe/redis/redis.go
index e29a626..52568c0 100644
--- 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: