From 586997afcca915eb281085ababfab91e68b208f3 Mon Sep 17 00:00:00 2001 From: ohkinozomu Date: Sat, 18 Nov 2023 17:49:00 +0900 Subject: [PATCH] Add buffer to channels --- internal/agent/agent.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/agent/agent.go b/internal/agent/agent.go index ec1af81..ad63d29 100644 --- 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