|
@@ -540,7 +540,7 @@ func authenticateHost(response http.ResponseWriter, request *http.Request) {
|
|
|
|
|
|
// Create EMQX creds and ACLs if not found
|
|
|
if servercfg.GetBrokerType() == servercfg.EmqxBrokerType {
|
|
|
- if err := mq.CreateEmqxUser(host.ID.String(), host.HostPass, false); err != nil {
|
|
|
+ if err := mq.CreateEmqxUser(host.ID.String(), authRequest.Password, false); err != nil {
|
|
|
slog.Error("failed to create host credentials for EMQX: ", err.Error())
|
|
|
} else {
|
|
|
if err := mq.CreateHostACL(host.ID.String(), servercfg.GetServerInfo().Server); err != nil {
|