x

chennqqi · Dec 11, 2017 · cdcfb77 · cdcfb77
1 parent 6cc5bcc
commit cdcfb77
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/nsqout/client.go b/nsqout/client.go
@@ -122,9 +122,9 @@ func (c *client) buildNsqMessages(events []publisher.Event) ([][]byte, error) {
 			err = nerr
 		} else {
 			//should copy, see https://blog.golang.org/go-slices-usage-and-internals
-			tmp := (serializedEvent)
+			tmp := string(serializedEvent)
 			//logp.Info("main:nsq] BuildMessage: %v", string(serializedEvent))
-			msgs[count] = (tmp) 
+			msgs[count] = []byte(tmp)
 			count++
 		}
 	}