| | |
| | | fmt.Errorf("Failed set MaxRecvSize: %v", err) |
| | | return |
| | | } |
| | | errTimeOut := sock.SetOption(mangos.OptionRecvDeadline,time.Millisecond * 3000) |
| | | errTimeOut := sock.SetOption(mangos.OptionRecvDeadline,time.Millisecond * 2000) |
| | | if errTimeOut != nil { |
| | | fmt.Errorf("Failed set MaxRecvDeadline: %v", err) |
| | | return |
| | |
| | | } |
| | | if msg, err = sock.Recv(); err != nil { |
| | | Die("接收响应失败: %s", err.Error()) |
| | | } else if msg, err = sock.Recv(); err == nil{ |
| | | logger.Debug("事件推送成功!收到响应",string(msg)) |
| | | } |
| | | logger.Debug("事件推送成功!收到响应",string(msg)) |
| | | sock.Close() |
| | | } |
| | | |