| | |
| | | return n.sock.Recv() |
| | | } |
| | | |
| | | // NewNNGProducer create from deliver Mode |
| | | func NewNNGProducer(m Mode, url string, args ...interface{}) *NNG { |
| | | // nngProducer create from deliver Mode |
| | | func nngProducer(m Mode, url string, args ...interface{}) *NNG { |
| | | |
| | | rmExistedIpcName(url) |
| | | if sock, err := newSocket(protoProducer(m)); err == nil { |
| | |
| | | return nil |
| | | } |
| | | |
| | | // NewNNGConsumer create from deliver Mode |
| | | func NewNNGConsumer(m Mode, url string, args ...interface{}) *NNG { |
| | | // nngConsumer create from deliver Mode |
| | | func nngConsumer(m Mode, url string, args ...interface{}) *NNG { |
| | | |
| | | if sock, err := newSocket(protoConsumer(m)); err == nil { |
| | | if err = setSocketOptions(sock, args); err != nil { |