From 1d4fe4652a4641a4f59410354395a23a29e1c434 Mon Sep 17 00:00:00 2001 From: Hoshina Date: Thu, 26 Feb 2026 22:46:57 +0800 Subject: [PATCH] fix(bus): increase message bus buffer size from 16 to 64 Prevents potential backpressure under load when multiple channels publish concurrently in gateway mode, where SDK callbacks blocking on a full buffer can cause message loss or timeouts. --- pkg/bus/bus.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/bus/bus.go b/pkg/bus/bus.go index 507a87d05..f2bf0c379 100644 --- a/pkg/bus/bus.go +++ b/pkg/bus/bus.go @@ -11,7 +11,7 @@ import ( // ErrBusClosed is returned when publishing to a closed MessageBus. var ErrBusClosed = errors.New("message bus closed") -const defaultBusBufferSize = 16 +const defaultBusBufferSize = 64 type MessageBus struct { inbound chan InboundMessage