rpc/send.go
@@ -85,13 +85,13 @@ } func (s *Sender) runShm(ctx context.Context) { c, err := deliver.NewClientWithError(deliver.Shm, s.ipcURL) c, err := deliver.NewServerWithError(deliver.Shm, s.ipcURL) for { if err == nil { break } time.Sleep(1 * time.Second) c, err = deliver.NewClientWithError(deliver.Shm, s.ipcURL) c, err = deliver.NewServerWithError(deliver.Shm, s.ipcURL) s.fnLogger("CLIENT CREATE FAILED : ", err) } s.run(ctx, c)