Fix runlocal (#271)

thought-machine · Nov 10, 2023 · ce6e22d · ce6e22d
1 parent 71d337e
commit ce6e22d
Showing 1 changed file with 5 additions and 3 deletions.
diff --git 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.