MM-23254: Add nil checks to WebSocketEventFromJson (#14050)

Automatic Merge
This commit is contained in:
Agniva De Sarker
2020-03-26 10:13:25 +05:30
committed by GitHub
parent 11debb55a6
commit 8812de2bf0
2 changed files with 6 additions and 0 deletions

View File

@@ -31,6 +31,9 @@ func (a *App) registerAllClusterMessageHandlers() {
func (a *App) clusterPublishHandler(msg *model.ClusterMessage) {
event := model.WebSocketEventFromJson(strings.NewReader(msg.Data))
if event == nil {
return
}
a.PublishSkipClusterSend(event)
}

View File

@@ -128,6 +128,9 @@ func (wsc *WebSocketClient) Listen() {
}
event := WebSocketEventFromJson(bytes.NewReader(rawMsg))
if event == nil {
continue
}
if event.IsValid() {
wsc.EventChannel <- event
continue