Merge pull request #8 from OpenMatchmaking/feature-batch-processing

Increased the number of prefetched messages in queues

Author: Relrin

auth/app/token/api/workers/generate_token.py

@@ -93,5 +93,5 @@ async def run(self, *args, **kwargs):
             exchange_name=self.REQUEST_EXCHANGE_NAME,
             routing_key=self.QUEUE_NAME
         )
-        await channel.basic_qos(prefetch_count=1, prefetch_size=0, connection_global=False)
+        await channel.basic_qos(prefetch_count=50, prefetch_size=0, connection_global=False)
         await channel.basic_consume(self.consume_callback, queue_name=self.QUEUE_NAME)

auth/app/token/api/workers/refresh_token.py

@@ -115,5 +115,5 @@ async def run(self, *args, **kwargs):
             exchange_name=self.REQUEST_EXCHANGE_NAME,
             routing_key=self.QUEUE_NAME
         )
-        await channel.basic_qos(prefetch_count=1, prefetch_size=0, connection_global=False)
+        await channel.basic_qos(prefetch_count=50, prefetch_size=0, connection_global=False)
         await channel.basic_consume(self.consume_callback, queue_name=self.QUEUE_NAME)

auth/app/token/api/workers/verify_token.py

@@ -87,5 +87,5 @@ async def run(self, *args, **kwargs):
             exchange_name=self.REQUEST_EXCHANGE_NAME,
             routing_key=self.QUEUE_NAME
         )
-        await channel.basic_qos(prefetch_count=1, prefetch_size=0, connection_global=False)
+        await channel.basic_qos(prefetch_count=50, prefetch_size=0, connection_global=False)
         await channel.basic_consume(self.consume_callback, queue_name=self.QUEUE_NAME)

auth/app/users/api/workers/register_game_client.py

@@ -103,5 +103,5 @@ async def run(self, *args, **kwargs):
             exchange_name=self.REQUEST_EXCHANGE_NAME,
             routing_key=self.QUEUE_NAME
         )
-        await channel.basic_qos(prefetch_count=1, prefetch_size=0, connection_global=False)
+        await channel.basic_qos(prefetch_count=50, prefetch_size=0, connection_global=False)
         await channel.basic_consume(self.consume_callback, queue_name=self.QUEUE_NAME)

auth/app/users/api/workers/user_profile.py

@@ -131,5 +131,5 @@ async def run(self, *args, **kwargs):
             exchange_name=self.REQUEST_EXCHANGE_NAME,
             routing_key=self.QUEUE_NAME
         )
-        await channel.basic_qos(prefetch_count=1, prefetch_size=0, connection_global=False)
+        await channel.basic_qos(prefetch_count=50, prefetch_size=0, connection_global=False)
         await channel.basic_consume(self.consume_callback, queue_name=self.QUEUE_NAME)

docker-compose.dev.yml

@@ -33,7 +33,7 @@ services:
     tty: true
 
   mongodb:
-    image: bitnami/mongodb:3.7
+    image: bitnami/mongodb:4.1
     ports:
       - "27017:27017"
     environment: