diff --git a/src/go/plugins/external/broker.go b/src/go/plugins/external/broker.go index a6740bf5023..50fb01d5cf4 100644 --- a/src/go/plugins/external/broker.go +++ b/src/go/plugins/external/broker.go @@ -26,21 +26,21 @@ import ( "net" "time" "golang.zabbix.com/sdk/conf" "golang.zabbix.com/sdk/errs" "golang.zabbix.com/sdk/log" "golang.zabbix.com/sdk/plugin" "golang.zabbix.com/sdk/plugin/comms" ) -const queSize = 100 +const queSize = 1 type pluginBroker struct { pluginName string socket string timeout time.Duration conn net.Conn requests map[uint32]chan any errx chan error log chan any // channel to handle agent->plugin requests