add send msg param

zhangmeng

2019-08-30 383557064fd77c028fd71facf8ec1cf6b278d3e6

add send msg param

 nng.go

@@ -28,6 +28,8 @@
    mode Mode
    url  string

    sendMsg *mangos.Message

    arguments []interface{}
}

@@ -49,9 +51,16 @@
        time.Sleep(time.Duration(surveyorTime*2) * time.Second)
    }

    msg := mangos.NewMessage(len(data))
    msg.Body = data
    return n.sock.SendMsg(msg)
    // msg := mangos.NewMessage(len(data))
    // msg.Body = data
    // return n.sock.SendMsg(msg)

    if n.sendMsg == nil {
        n.sendMsg = &mangos.Message{}
        n.sendMsg.Header = make([]byte, 32)
    }
    n.sendMsg.Body = data
    return n.sock.SendMsg(n.sendMsg)

}