给事件推送设置响应超时

panlei

2019-10-25 79c8a582be31f49f0fab414771a0bbbab2224172

 labelFilter/req.go

@@ -66,6 +66,11 @@
      fmt.Errorf("Failed set MaxRecvSize: %v", err)
      return
   }
   errTimeOut := sock.SetOption(mangos.OptionRecvDeadline,time.Millisecond * 500)
   if errTimeOut != nil {
      fmt.Errorf("Failed set MaxRecvSize: %v", err)
      return
   }
   //sock.AddTransport(ipc.NewTransport())
   sock.AddTransport(tcp.NewTransport())
   if err = sock.Dial(url); err != nil {