fix race on reuse msg

mehrdadrad · mehrdadrad · commit 5ec871065123 · 2017-04-05T22:28:36.000Z
diff --git a/producer/nsq.go b/producer/nsq.go
@@ -72,7 +72,7 @@ func (n *NSQ) inputMsg(topic string, mCh chan []byte, ec *uint64) {
 			break
 		}
 
-		err = n.producer.Publish(topic, msg)
+		err = n.producer.Publish(topic, append([]byte{}, msg...))
 		if err != nil {
 			n.logger.Println(err)
 			*ec++

Original file line number	Diff line number	Diff line change
`@@ -72,7 +72,7 @@ func (n NSQ) inputMsg(topic string, mCh chan []byte, ec uint64) {`
`72`	`72`	`break`
`73`	`73`	`}`
`74`	`74`
`75`		`- err = n.producer.Publish(topic, msg)`
	`75`	`+ err = n.producer.Publish(topic, append([]byte{}, msg...))`
`76`	`76`	`if err != nil {`
`77`	`77`	`n.logger.Println(err)`
`78`	`78`	`*ec++`