| | |
| | | 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.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) |
| | | |
| | | } |
| | | s = i |
| | | // fmt.Println("client create failed : ", err) |
| | | |
| | | // } |
| | | // s = i |
| | | |
| | | fmt.Printf("can't send message on push socket: %s\n", err.Error()) |
| | | } else { |