diff --git a/broker/broker.go b/broker/broker.go index 5d6f7c8..e838423 100644 --- a/broker/broker.go +++ b/broker/broker.go @@ -285,6 +285,7 @@ func (b *Broker) StartUnixSocketClientListening(socketPath string, unixSocket bo if unixSocket { if FileExist(socketPath) { if err != nil { + err = os.Remove(socketPath) log.Error("Remove Unix socketPath ", zap.Error(err)) } }