Use the accessor, duh.

Author: rafrombrc

plugins/file/file_output.go

@@ -267,11 +267,7 @@ func (o *FileOutput) handleMessage(pack *PipelinePack, outBytes *[]byte) (err er
 			err = fmt.Errorf("Can't encode to JSON: %s", err)
 		}
 	case "text":
-		if pack.Message.Payload == nil {
-			*outBytes = append(*outBytes, []byte("<NIL>")...)
-		} else {
-			*outBytes = append(*outBytes, *pack.Message.Payload...)
-		}
+		*outBytes = append(*outBytes, pack.Message.GetPayload()...)
 		*outBytes = append(*outBytes, NEWLINE)
 	case "protobufstream":
 		if err = ProtobufEncodeMessage(pack, &*outBytes); err != nil {

plugins/file/file_output_test.go

@@ -92,7 +92,7 @@ func FileOutputSpec(c gs.Context) {
 				err = fileOutput.handleMessage(pack, &outData)
 				c.Expect(err, gs.IsNil)
 				strContents := toString(&outData)
-				c.Expect(strContents, gs.Equals, "<NIL>\n")
+				c.Expect(strContents, gs.Equals, "\n")
 			})
 
 			c.Specify("payload is nil and with a timestamp", func() {
@@ -105,7 +105,7 @@ func FileOutputSpec(c gs.Context) {
 				todayStr := time.Now().Format("[2006/Jan/02:")
 				strContents := toString(&outData)
 				c.Expect(strings.HasPrefix(strContents, todayStr), gs.IsTrue)
-				c.Expect(strings.HasSuffix(strContents, "<NIL>\n"), gs.IsTrue)
+				c.Expect(strings.HasSuffix(strContents, " \n"), gs.IsTrue)
 			})
 		})