From ce6e22d8d8c236cee8eb1a5d35780626534ebf7d Mon Sep 17 00:00:00 2001 From: Jonathan Poole Date: Fri, 10 Nov 2023 17:44:38 +0000 Subject: [PATCH] Fix runlocal (#271) --- 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.