diff --git a/mqtt-gateway/config/config.go b/mqtt-gateway/config/config.go index b386c89..87ac2a9 100644 --- a/mqtt-gateway/config/config.go +++ b/mqtt-gateway/config/config.go @@ -7,6 +7,8 @@ import ( type Config struct { MQTTAddr string MQTTClientID string + MQTTUser string + MQTTPassword string RedisAddr string RedisPassword string IncomingQueueKey string @@ -18,6 +20,8 @@ func LoadConfig() *Config { return &Config{ MQTTAddr: getEnv("MQTT_BROKER_ADDR", "tcp://emqx:1883"), MQTTClientID: getEnv("MQTT_GATEWAY_CLIENT_ID", "star-cloud-gateway"), + MQTTUser: getEnv("MQTT_USER", "star-cloud-gateway"), + MQTTPassword: getEnv("MQTT_PASSWORD", "StarCloudSecret999"), RedisAddr: getEnv("MQTT_REDIS_ADDR", "star-cloud-redis:6379"), RedisPassword: getEnv("MQTT_REDIS_PASSWORD", ""), IncomingQueueKey: getEnv("MQTT_INCOMING_QUEUE", "mqtt_incoming_jobs"),