| | |
| | | } |
| | | sock.AddTransport(ipc.NewTransport()) |
| | | sock.AddTransport(tcp.NewTransport()) |
| | | sock.SetOption(mangos.OptionMaxRecvSize, 1024*1024*100) |
| | | //sock.SetOption(mangos.OptionRecvDeadline, time.Second*10) |
| | | if err = sock.Dial(url);err !=nil { |
| | | logger.Debug("can't dial on req socket:%s",err.Error()) |
| | | return nil |
| | | } |
| | | sock.SetOption(mangos.OptionMaxRecvSize, 1024*1024*100) |
| | | //sock.SetOption(mangos.OptionRecvDeadline, time.Second*10) |
| | | if err = sock.Send(args);err !=nil { |
| | | logger.Debug("can't send message on push socket:%s",err.Error()) |
| | | return nil |