mqttim

commit 980a7c8cdf611f8b786d23d816068816725a1110
parent d6a91feabbd2e63a4199797f9beb0a62f61ab83b
Author: Natasha Kerensikova <natgh@instinctive.eu>
Date:   Sat, 18 Jan 2025 18:12:11 +0000

MQTT session name is configurable
Diffstat:
M
main.go
 | 
3
++-

1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/main.go b/main.go
@@ -28,6 +28,7 @@ type IrcConfig struct {
 
 type MqttConfig struct {
 	Server   string
+	Session  string
 	UserName string
 	Password string
 }
@@ -72,7 +73,7 @@ func main() {
 		return
 	}
 
-	m, err = mqtt.VolatileSession("mqttim", &mqtt.Config{
+	m, err = mqtt.VolatileSession(config.Mqtt.Session, &mqtt.Config{
 		Dialer:       mqtt.NewDialer("tcp", config.Mqtt.Server),
 		PauseTimeout: 4 * time.Second,
 		UserName:     config.Mqtt.UserName,