make a copy of msg.Data before calling client.Write

compose · Jan 24, 2017 · 7d8b223 · 7d8b223
1 parent 19f443d
commit 7d8b223
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/pkg/adaptor/elasticsearch/elasticsearch.go b/pkg/adaptor/elasticsearch/elasticsearch.go
@@ -165,7 +165,12 @@ func (e *Elasticsearch) Stop() error {
 
 func (e *Elasticsearch) applyOp(msg message.Msg) (message.Msg, error) {
 	_, msgColl, _ := message.SplitNamespace(msg)
-	err := e.client.Write(message.From(msg.OP(), e.computeNamespace(msgColl), msg.Data()))(nil)
+	var msgCopy map[string]interface{}
+	// Copy from the original map to the target map
+	for key, value := range msg.Data() {
+		msgCopy[key] = value
+	}
+	err := e.client.Write(message.From(msg.OP(), e.computeNamespace(msgColl), msgCopy))(nil)
 
 	if err != nil {
 		e.pipe.Err <- adaptor.NewError(adaptor.ERROR, e.path, fmt.Sprintf("write message error (%s)", err), msg.Data)