fix crash

zhangmeng

2019-05-17 36766ab5b68ce7dfb39dff5d6d283ce5c7f4b346

 deliver.go

@@ -8,22 +8,25 @@

   // Recv recv data
   Recv() ([]byte, error)

   // Close close Deliver
   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 NewNNGProducer(m, url, args)
      return nngServer(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 NewNNGConsumer(m, url, args)
      return nngClient(m, url, args...)
   }

   return nil