bug fix reverse

554325746@qq.com

2019-08-21 3603e569db5a358cdb8ff7d645566e7718a815f9

 deliver.go

@@ -76,3 +76,35 @@

   return nil, errors.New("please choose a suitable deliver.mode")
}

// NewServerWithTimeout with timeout
func NewServerWithTimeout(m Mode, url string, tm int, args ...interface{}) (Deliver, error) {
   if m > ModeStart && m < ModeNNG {
      setTimeOut(tm)
      s := nngServer(m, url, args...)
      if s == nil {
         return nil, errors.New("nng create server error")
      }
      return s, nil
   } else if m == Shm {
      return shmServer(m, url, args...)
   }
   return nil, errors.New("please choose a suitable deliver.mode")
}

// NewClientWithTimeout with timeout, tm unit millisecond
func NewClientWithTimeout(m Mode, url string, tm int, args ...interface{}) (Deliver, error) {
   if m > ModeStart && m < ModeNNG {
      setTimeOut(tm)

      s := nngClient(m, url, args...)
      if s == nil {
         return nil, errors.New("nng create client error")
      }
      return s, nil
   } else if m == Shm {
      return shmClient(m, url, args...)
   }

   return nil, errors.New("please choose a suitable deliver.mode")
}