mqttagent

commit 8abf503663b9957d0e545aaf42f89da8d7149c43
parent 2c7a0443390b47f9f02e902f884ecd24ac0354c0
Author: Natasha Kerensikova <natgh@instinctive.eu>
Date:   Fri,  7 Feb 2025 19:33:13 +0000

MQTT channel is buffered
Diffstat:
M
cmd/mqttagent-full/main.go
 | 
2
+-
M
cmd/mqttagent-lite/main.go
 | 
2
+-
M
mqttagent.go
 | 
4
++--

3 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/cmd/mqttagent-full/main.go b/cmd/mqttagent-full/main.go
@@ -171,7 +171,7 @@ func main() {
 		main_script = os.Args[1]
 	}
 
-	mqttagent.Run(&agent, main_script)
+	mqttagent.Run(&agent, main_script, 10)
 
 	os.Exit(0)
 }
diff --git a/cmd/mqttagent-lite/main.go b/cmd/mqttagent-lite/main.go
@@ -37,7 +37,7 @@ func main() {
 		main_script = os.Args[1]
 	}
 
-	mqttagent.Run(agent, main_script)
+	mqttagent.Run(agent, main_script, 10)
 
 	os.Exit(0)
 }
diff --git a/mqttagent.go b/mqttagent.go
@@ -42,8 +42,8 @@ type MqttMessage struct {
 	Message   []byte
 }
 
-func Run(agent MqttAgent, main_script string) {
-	fromMqtt := make(chan MqttMessage)
+func Run(agent MqttAgent, main_script string, capacity int) {
+	fromMqtt := make(chan MqttMessage, capacity)
 
 	L := lua.NewState()
 	defer L.Close()