Add buffer to channels

ohkinozomu · Nov 18, 2023 · 586997a · 586997a
1 parent 39ec15a
commit 586997a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/internal/agent/agent.go b/internal/agent/agent.go
@@ -87,8 +87,8 @@ func newServer(c AgentConfig) server {
 		c.Logger.Fatal("Error parsing MQTT broker URL: " + err.Error())
 	}
 
-	payloadCh := make(chan []byte)
-	mergeCh := make(chan mergeChPayload)
+	payloadCh := make(chan []byte, 1000)
+	mergeCh := make(chan mergeChPayload, 1000)
 	processCh := make(chan processChPayload, 1000)
 
 	var connectUsername string