nng.go
@@ -49,10 +49,9 @@ time.Sleep(time.Duration(surveyorTime*2) * time.Second) } msg := mangos.NewMessage(len(data)) msg := mangos.NewMessage(1) msg.Body = data return n.sock.SendMsg(msg) } // Recv impl interface Diliver @@ -149,6 +148,8 @@ if s[0] == "ipc" { if _, err := os.Stat(s[1]); err == nil { os.Remove(s[1]) } else if !os.IsNotExist(err) { os.Remove(s[1]) } } }