From c263127713f70f02ed1e7d0b38a81317a5837c7d Mon Sep 17 00:00:00 2001 From: Jon Poole Date: Fri, 10 Nov 2023 13:20:33 +0000 Subject: [PATCH] Fix runlocal --- mettle/main.go | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/mettle/main.go b/mettle/main.go index b70793bb..d2a88cb4 100644 --- a/mettle/main.go +++ b/mettle/main.go @@ -164,9 +164,11 @@ func main() { const requests = "mem://requests" const responses = "mem://responses" queues := api.PubSubOpts{ - RequestQueue: requests, - ResponseQueue: responses, - NumPollers: 1, + RequestQueue: requests, + ResponseQueue: responses, + PreResponseQueue: responses, + NumPollers: 1, + SubscriptionBatchSize: 100, } // Must ensure the topics are created ahead of time.