zhangmeng
2019-05-22 a8b90cfcf722f4b1c4aac9f318e35824f02b8787
deliver.go
@@ -13,20 +13,24 @@
   Close()
}
// NewProducer create producer args presentive for parameter with protocal, e.g. sub topic
func NewProducer(m Mode, url string, args ...interface{}) Deliver {
// NewServer create listener args presentive for parameter with protocal, e.g. sub topic
func NewServer(m Mode, url string, args ...interface{}) Deliver {
   if m > ModeStart && m < ModeNNG {
      return nngProducer(m, url, args...)
      return nngServer(m, url, args...)
   } else if m == Shm {
      return shmServer(m, url, args...)
   }
   return nil
}
// NewConsumer create consumer args presentive for parameter with protocal, e.g. sub topic
func NewConsumer(m Mode, url string, args ...interface{}) Deliver {
// NewClient create dialer args presentive for parameter with protocal, e.g. sub topic
func NewClient(m Mode, url string, args ...interface{}) Deliver {
   if m > ModeStart && m < ModeNNG {
      return nngConsumer(m, url, args...)
      return nngClient(m, url, args...)
   } else if m == Shm {
      return shmClient(m, url, args...)
   }
   return nil