diff options
| -rw-r--r-- | weed/mq/client/pub_client/scheduler.go | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/weed/mq/client/pub_client/scheduler.go b/weed/mq/client/pub_client/scheduler.go index c32343e0d..03377d653 100644 --- a/weed/mq/client/pub_client/scheduler.go +++ b/weed/mq/client/pub_client/scheduler.go @@ -241,6 +241,7 @@ func (p *TopicPublisher) doConfigureTopic() (err error) { return err }) if err == nil { + lastErr = nil return nil } else { lastErr = fmt.Errorf("%s: %v", brokerAddress, err) |