Merge pull request #54 from openfresh/feature/fix_close_channel_panic

fixed panic to send closed channel

manager/client.go

@@ -110,7 +110,7 @@ func (cm *ClientManager) SendPayload(payload event.Payload) {
 				wg2.Add(1)
 				go func(client chan event.Payload) {
 					defer wg2.Done()
-					client <- payload
+					sendPayloadSafety(client, payload)
 				}(client)
 			}
 			wg2.Wait()
@@ -119,6 +119,16 @@ func (cm *ClientManager) SendPayload(payload event.Payload) {
 	wg.Wait()
 }
 
+func sendPayloadSafety(client chan event.Payload, payload event.Payload) {
+	defer func() {
+		if err := recover(); err != nil {
+			return
+		}
+	}()
+	client <- payload
+	return
+}
+
 const heartBeatEvent = "heartbeat"
 
 func (cm *ClientManager) SendHeartBeat() {