From a8273a816ccfabe7e9a610e49a471afa982ff914 Mon Sep 17 00:00:00 2001
From: crusader <crusader@loafle.com>
Date: Fri, 13 Apr 2018 20:03:36 +0900
Subject: [PATCH] ing

---
 subscribe/redis/redis.go | 4 ++++
 1 file changed, 4 insertions(+)

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: