add close

zhangmeng

2019-05-15 aaae9917c3df122e2bbcf591417c1b58021d79fc

 deliver.go

@@ -8,13 +8,16 @@

   // 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 {

   if m > ModeStart && m < ModeNNG {
      return nngProducer(m, url, args)
      return nngProducer(m, url, args...)
   }
   return nil
}
@@ -23,7 +26,7 @@
func NewConsumer(m Mode, url string, args ...interface{}) Deliver {

   if m > ModeStart && m < ModeNNG {
      return nngConsumer(m, url, args)
      return nngConsumer(m, url, args...)
   }

   return nil