Skip to content

Commit 262bdbf

Browse files
fix: mqtt pasword value
1 parent 6c413a3 commit 262bdbf

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

config/server.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -137,7 +137,7 @@ func serverMQTTConfigLoader() {
137137
},
138138
AuthConfig: auth{
139139
Username: util.MustGetString("SERVER_MQTT_AUTH_USERNAME"),
140-
Password: util.MustGetString("SERVER_MQTT_AUTH_USERNAME"),
140+
Password: util.MustGetString("SERVER_MQTT_AUTH_PASSWORD"),
141141
},
142142
ConsumerConfig: consumer{
143143
RetryIntervalInSec: util.MustGetDuration("SERVER_MQTT_CONSUMER_RETRY_INTERVAL_IN_SEC", time.Second),

services/mqtt/client/cred.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ func newCredentialFetcher() (*credentialFetcher, error) {
3636

3737
// Credentials returns the MQTT username and password as a courier.Credential.
3838
func (cf *credentialFetcher) Credentials(_ context.Context) (*courier.Credential, error) {
39-
logger.Info("username : %v \n password : %v", cf.username, cf.password)
39+
logger.Infof("username : %v \n password : %v", cf.username, cf.password)
4040
return &courier.Credential{
4141
Username: cf.username,
4242
Password: cf.password,

0 commit comments

Comments
 (0)