Merge pull request #2849 from gravitl/ACC-468

delete server user on start up to re-initialize
This commit is contained in:
Abhishek K 2024-03-05 12:04:47 +07:00 committed by GitHub
commit e7eb40ab1f
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 2 additions and 1 deletions

View file

@ -307,7 +307,7 @@ func MigrateEmqx() {
slog.Info("proceeding to kicking out clients from emqx")
err = mq.KickOutClients()
if err != nil {
logger.Log(0, "failed to migrate emqx: ", "kickout-error", err.Error())
logger.Log(2, "failed to migrate emqx: ", "kickout-error", err.Error())
}
}

View file

@ -60,6 +60,7 @@ func SetupMQTT() {
log.Fatal(err)
}
} else {
emqx.DeleteEmqxUser(servercfg.GetMqUserName())
if err := emqx.CreateEmqxUserforServer(); err != nil {
log.Fatal(err)
}