diff options
| author | chrislu <chris.lu@gmail.com> | 2024-05-05 14:16:54 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-05-05 14:16:54 -0700 |
| commit | 4e3701df77aa405daab1146944b0691db1c9e1bf (patch) | |
| tree | 1edc3996f0345a7c19a08af694acd2f7bf6bba15 | |
| parent | 658d302aa4ecd43e1463f9ff54bdc0f29954b7d3 (diff) | |
| download | seaweedfs-4e3701df77aa405daab1146944b0691db1c9e1bf.tar.xz seaweedfs-4e3701df77aa405daab1146944b0691db1c9e1bf.zip | |
reset last error
| -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) |