fix variable

elastic · Aug 27, 2018 · 496ebe4 · 496ebe4
1 parent 03ee796
commit 496ebe4
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/filebeat/reader/message.go b/filebeat/reader/message.go
@@ -55,10 +55,10 @@ func (m *Message) AddFields(fields common.MapStr) {
 		return
 	}
 
-	if msg.Fields == nil {
-		msg.Fields = common.MapStr{}
+	if m.Fields == nil {
+		m.Fields = common.MapStr{}
 	}
-	msg.Fields.Update(fields)
+	m.Fields.Update(fields)
 }
 
 // AddTagsWithKey adds tags to the message with an arbitrary key.
@@ -68,9 +68,9 @@ func (m *Message) AddTagsWithKey(key string, tags []string) error {
 		return nil
 	}
 
-	if msg.Fields == nil {
-		msg.Fields = common.MapStr{}
+	if m.Fields == nil {
+		m.Fields = common.MapStr{}
 	}
 
-	return common.AddTagsWithKey(msg.Fields, key, tags)
+	return common.AddTagsWithKey(m.Fields, key, tags)
 }