From 2c799e282c350eb9c1751f532ac471ad3cbce12f Mon Sep 17 00:00:00 2001
From: 1kasa <3049907027@qq.com>
Date: Fri, 7 Feb 2025 01:20:37 +0800
Subject: [PATCH] fix subscribe from registry

---
 registry/directory/directory.go | 18 +++++++++++++-----
 1 file changed, 13 insertions(+), 5 deletions(-)

diff --git a/registry/directory/directory.go b/registry/directory/directory.go
index 802bf06f9..2252cb0bb 100644
--- a/registry/directory/directory.go
+++ b/registry/directory/directory.go
@@ -124,12 +124,20 @@ func (dir *RegistryDirectory) Subscribe(url *common.URL) error {
 	registerUrl := dir.registry.GetURL()
 
 	var timeoutStr string
-	if registerUrl == nil {
-		timeoutStr = url.GetParam(constant.TimeoutKey, "1s")
-	} else {
-		timeoutStr = registerUrl.GetParam(constant.RegistryTimeoutKey, "")
+
+	if registerUrl != nil {
+		if val := registerUrl.GetParam(constant.RegistryTimeoutKey, ""); val != "" {
+			timeoutStr = val
+		}
 	}
-	timeout, _ := time.ParseDuration(timeoutStr)
+
+	timeout, err := time.ParseDuration(timeoutStr)
+	if err != nil {
+		logger.Warnf("Invalid timeout value %s, using default %s", timeoutStr, constant.DefaultRegTimeout)
+		timeout, _ = time.ParseDuration(constant.DefaultRegTimeout)
+	}
+
+	fmt.Println("timeout:\n\n", timeout)
 
 	done := make(chan struct{})