Increased the number of prefetched messages in queues

Relrin · Relrin · commit 07caafbca05f · 2018-12-19T15:06:42.000+03:00
diff --git a/auth/app/token/api/workers/generate_token.py b/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)
diff --git a/auth/app/token/api/workers/refresh_token.py b/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)
diff --git a/auth/app/token/api/workers/verify_token.py b/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)
diff --git a/auth/app/users/api/workers/register_game_client.py b/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)
diff --git a/auth/app/users/api/workers/user_profile.py b/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)

Original file line number	Diff line number	Diff line change
`@@ -93,5 +93,5 @@ async def run(self, args, *kwargs):`
`93`	`93`	`exchange_name=self.REQUEST_EXCHANGE_NAME,`
`94`	`94`	`routing_key=self.QUEUE_NAME`
`95`	`95`	`)`
`96`		`- await channel.basic_qos(prefetch_count=1, prefetch_size=0, connection_global=False)`
	`96`	`+ await channel.basic_qos(prefetch_count=50, prefetch_size=0, connection_global=False)`
`97`	`97`	`await channel.basic_consume(self.consume_callback, queue_name=self.QUEUE_NAME)`
Original file line number	Diff line number	Diff line change
`@@ -115,5 +115,5 @@ async def run(self, args, *kwargs):`
`115`	`115`	`exchange_name=self.REQUEST_EXCHANGE_NAME,`
`116`	`116`	`routing_key=self.QUEUE_NAME`
`117`	`117`	`)`
`118`		`- await channel.basic_qos(prefetch_count=1, prefetch_size=0, connection_global=False)`
	`118`	`+ await channel.basic_qos(prefetch_count=50, prefetch_size=0, connection_global=False)`
`119`	`119`	`await channel.basic_consume(self.consume_callback, queue_name=self.QUEUE_NAME)`
Original file line number	Diff line number	Diff line change
`@@ -87,5 +87,5 @@ async def run(self, args, *kwargs):`
`87`	`87`	`exchange_name=self.REQUEST_EXCHANGE_NAME,`
`88`	`88`	`routing_key=self.QUEUE_NAME`
`89`	`89`	`)`
`90`		`- await channel.basic_qos(prefetch_count=1, prefetch_size=0, connection_global=False)`
	`90`	`+ await channel.basic_qos(prefetch_count=50, prefetch_size=0, connection_global=False)`
`91`	`91`	`await channel.basic_consume(self.consume_callback, queue_name=self.QUEUE_NAME)`
Original file line number	Diff line number	Diff line change
`@@ -103,5 +103,5 @@ async def run(self, args, *kwargs):`
`103`	`103`	`exchange_name=self.REQUEST_EXCHANGE_NAME,`
`104`	`104`	`routing_key=self.QUEUE_NAME`
`105`	`105`	`)`
`106`		`- await channel.basic_qos(prefetch_count=1, prefetch_size=0, connection_global=False)`
	`106`	`+ await channel.basic_qos(prefetch_count=50, prefetch_size=0, connection_global=False)`
`107`	`107`	`await channel.basic_consume(self.consume_callback, queue_name=self.QUEUE_NAME)`
Original file line number	Diff line number	Diff line change
`@@ -131,5 +131,5 @@ async def run(self, args, *kwargs):`
`131`	`131`	`exchange_name=self.REQUEST_EXCHANGE_NAME,`
`132`	`132`	`routing_key=self.QUEUE_NAME`
`133`	`133`	`)`
`134`		`- await channel.basic_qos(prefetch_count=1, prefetch_size=0, connection_global=False)`
	`134`	`+ await channel.basic_qos(prefetch_count=50, prefetch_size=0, connection_global=False)`
`135`	`135`	`await channel.basic_consume(self.consume_callback, queue_name=self.QUEUE_NAME)`