| 提交 | 用户 | age | ||
| 9d4b12 | 1 | package deliver |
| Z | 2 | |
| 3 | // Deliver define a interface how to use mangos | |
| 4 | type Deliver interface { | |
| 5 | ||
| 6 | // Send send data | |
| 7 | Send([]byte) error | |
| 8 | ||
| 9 | // Recv recv data | |
| 10 | Recv() ([]byte, error) | |
| 11 | } | |
| 12 | ||
| 13 | // NewProducer create producer args presentive for parameter with protocal, e.g. sub topic | |
| 14 | func NewProducer(m Mode, url string, args ...interface{}) Deliver { | |
| 15 | ||
| 16 | if m > ModeStart && m < ModeNNG { | |
| 17 | return NewNNGProducer(m, url, args) | |
| 18 | } | |
| 19 | return nil | |
| 20 | } | |
| 21 | ||
| 22 | // NewConsumer create consumer args presentive for parameter with protocal, e.g. sub topic | |
| 23 | func NewConsumer(m Mode, url string, args ...interface{}) Deliver { | |
| 24 | ||
| 25 | if m > ModeStart && m < ModeNNG { | |
| 26 | return NewNNGConsumer(m, url, args) | |
| 27 | } | |
| 28 | ||
| 29 | return nil | |
| 30 | } | |
