From f8cb9692c505323aca3dc31a843799f9f80fc4e2 Mon Sep 17 00:00:00 2001 From: virgilio-a-cunha-alb Date: Thu, 12 Mar 2026 14:49:52 +0000 Subject: [PATCH 1/2] Bus Buffer Size Configurable --- stdbus/bus.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/stdbus/bus.go b/stdbus/bus.go index 5583c81..7de625a 100644 --- a/stdbus/bus.go +++ b/stdbus/bus.go @@ -2,6 +2,8 @@ package stdbus import ( "sync" + "os" + "strconv" "github.com/CyCoreSystems/ari/v6" ) @@ -27,6 +29,11 @@ func New() ari.Bus { subs: []*subscription{}, } + if os.Getenv("BUS_BUFFERSIZE") != "" { + size := os.Getenv("BUS_BUFFERSIZE") + subscriptionEventBufferSize, _ = strconv.Atoi(size) + } + return b } From bdb1271327827ac2ef4e288e6ffa732159611dc1 Mon Sep 17 00:00:00 2001 From: virgilio-a-cunha-alb Date: Fri, 13 Mar 2026 10:06:22 +0000 Subject: [PATCH 2/2] Safely parse BUS_BUFFERSIZE environment variable --- stdbus/bus.go | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/stdbus/bus.go b/stdbus/bus.go index 7de625a..725a2c3 100644 --- a/stdbus/bus.go +++ b/stdbus/bus.go @@ -29,9 +29,11 @@ func New() ari.Bus { subs: []*subscription{}, } - if os.Getenv("BUS_BUFFERSIZE") != "" { - size := os.Getenv("BUS_BUFFERSIZE") - subscriptionEventBufferSize, _ = strconv.Atoi(size) + if size := os.Getenv("BUS_BUFFERSIZE"); size != "" { + sizeInt, err := strconv.Atoi(size) + if err == nil && sizeInt > 0 { + subscriptionEventBufferSize = sizeInt + } } return b