zhangmeng
2019-05-22 c2bbe31e7c6c9f83f7bcce26dea98bc18ed8f39c
deliver.go
@@ -1,5 +1,7 @@
package deliver
import "errors"
// Deliver define a interface how to use mangos
type Deliver interface {
@@ -19,7 +21,8 @@
   if m > ModeStart && m < ModeNNG {
      return nngServer(m, url, args...)
   } else if m == Shm {
      return shmServer(m, url, args...)
      s, _ := shmServer(m, url, args...)
      return s
   }
   return nil
}
@@ -30,8 +33,32 @@
   if m > ModeStart && m < ModeNNG {
      return nngClient(m, url, args...)
   } else if m == Shm {
      return shmClient(m, url, args...)
      s, _ := shmClient(m, url, args...)
      return s
   }
   return nil
}
// NewServerWithError create listener args presentive for parameter with protocal, e.g. sub topic
func NewServerWithError(m Mode, url string, args ...interface{}) (Deliver, error) {
   if m > ModeStart && m < ModeNNG {
      return nngServer(m, url, args...), nil
   } else if m == Shm {
      return shmServer(m, url, args...)
   }
   return nil, errors.New("please choose a suitable deliver.mode")
}
// NewClientWithError create dialer args presentive for parameter with protocal, e.g. sub topic
func NewClientWithError(m Mode, url string, args ...interface{}) (Deliver, error) {
   if m > ModeStart && m < ModeNNG {
      return nngClient(m, url, args...), nil
   } else if m == Shm {
      return shmClient(m, url, args...)
   }
   return nil, errors.New("please choose a suitable deliver.mode")
}