diff --git a/server.go b/server.go index 67a9136c6..b3e42a4c8 100644 --- a/server.go +++ b/server.go @@ -345,13 +345,15 @@ func (s *Server) SendSync(pb proto.Message) error { return err } - // Don't forward the message to ourselves - if *s.URI != *uri { - ctx := context.WithValue(context.Background(), "uri", uri) - eg.Go(func() error { - return s.defaultClient.ClusterMessage(ctx, pb) - }) + // Don't forward the message to ourselves. + if *s.URI == *uri { + continue } + + ctx := context.WithValue(context.Background(), "uri", uri) + eg.Go(func() error { + return s.defaultClient.ClusterMessage(ctx, pb) + }) } return eg.Wait()