fix(producer): update name server address immediately when client start ; or end up with a failed publish (#436)
diff --git a/internal/client.go b/internal/client.go
index 72debb0..a84aa33 100644
--- a/internal/client.go
+++ b/internal/client.go
@@ -262,6 +262,7 @@
}
// fetchNameServerAddr
if len(c.option.NameServerAddrs) == 0 {
+ c.namesrvs.UpdateNameServerAddress(c.option.NameServerDomain, c.option.InstanceName)
go primitive.WithRecover(func() {
op := func() {
c.namesrvs.UpdateNameServerAddress(c.option.NameServerDomain, c.option.InstanceName)
