zhangmeng
2019-08-26 b6d2aeec8bd849c70028c01943968eba26474ea4
profile/shmsend.go
@@ -22,6 +22,20 @@
         return
      default:
         if err = s.Send(buf); err != nil {
            s.Close()
            url := "hello"
            i, err := deliver.NewClientWithError(deliver.Shm, url)
            for {
               if err == nil {
                  break
               }
               time.Sleep(1 * time.Second)
               i, err = deliver.NewClientWithError(deliver.Shm, url)
               fmt.Println("client create failed : ", err)
            }
            s = i
            fmt.Printf("can't send message on push socket: %s\n", err.Error())
         } else {