Skip to content

Commit

Permalink
fix subscribe from registry
Browse files Browse the repository at this point in the history
  • Loading branch information
1kasa committed Feb 6, 2025
1 parent e461642 commit b21f89e
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions registry/directory/directory.go
Original file line number Diff line number Diff line change
Expand Up @@ -139,10 +139,10 @@ func (dir *RegistryDirectory) Subscribe(url *common.URL) error {

select {
case <-done:
logger.Infof("Register completed successfully for service: %s", url.Key())
logger.Infof("register completed successfully for service: %s", url.Key())
return nil
case <-time.After(timeout):
logger.Errorf("Register timed out for service: %s", url.Key())
logger.Errorf("register timed out for service: %s", url.Key())
return fmt.Errorf("register timed out for service: %s", url.Key())
}
}
Expand Down

0 comments on commit b21f89e

Please sign in to comment.