Logged proto message when deserialization fails. #231

getgauge · Jul 17, 2019 · 78a9400 · 78a9400
1 parent f07dfba
commit 78a9400
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/listener/gaugeListener.go b/listener/gaugeListener.go
@@ -81,9 +81,11 @@ func (gaugeListener *GaugeListener) processMessages(buffer *bytes.Buffer) {
 		if messageLength > 0 && messageLength < uint64(buffer.Len()) {
 			message := &gauge_messages.Message{}
 			messageBoundary := int(messageLength) + bytesRead
-			err := proto.Unmarshal(buffer.Bytes()[bytesRead:messageBoundary], message)
+			messageBytes := buffer.Bytes()[bytesRead:messageBoundary]
+			err := proto.Unmarshal(messageBytes, message)
 			if err != nil {
 				logger.Warnf("Failed to read proto message: %s\n", err.Error())
+				logger.Warnf("Message : %s\n", string(messageBytes))
 			} else {
 				switch message.MessageType {
 				case gauge_messages.Message_KillProcessRequest: