fix(producer): update name server address immediately when client start ; or end up with a failed publish (apache#436)

hzjiangjian · web-flow · commit 2af5495d3b96 · 2020-02-28T20:34:58.000+08:00
diff --git a/internal/client.go b/internal/client.go
@@ -262,6 +262,7 @@ func (c *rmqClient) Start() {
 		}
 		// 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)

Original file line number	Diff line number	Diff line change
`@@ -262,6 +262,7 @@ func (c *rmqClient) Start() {`
`262`	`262`	`}`
`263`	`263`	`// fetchNameServerAddr`
`264`	`264`	`if len(c.option.NameServerAddrs) == 0 {`
	`265`	`+ c.namesrvs.UpdateNameServerAddress(c.option.NameServerDomain, c.option.InstanceName)`
`265`	`266`	`go primitive.WithRecover(func() {`
`266`	`267`	`op := func() {`
`267`	`268`	`c.namesrvs.UpdateNameServerAddress(c.option.NameServerDomain, c.option.InstanceName)`