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 {