fix: load_rpc_client

2023-10-26 12:39:07 +08:00 · 2023-10-26 12:39:07 +08:00 · 35ffe3554c
commit 35ffe3554c
parent bffcd78f99
1 changed files with 4 additions and 1 deletions
--- a/app/init.py
+++ b/app/init.py
@ -31,7 +31,10 @@ def load_rpc_client(apiflask_app):
    apiflask_app.config.update(dict(
        NAMEKO_AMQP_URI=str(Config.RABBITMQ_URI)
    ))
-    rpc.init_app(apiflask_app)
+    rpc.init_app(apiflask_app, extra_config={
+        'INITIAL_CONNECTIONS': 4,
+        'MAX_CONNECTIONS': 30,
+    })


 def create_app():