Merge pull request #673 from jeff-foster-trabon/robust_qos

mosquito · web-flow · commit 14a78245db86 · 2025-05-15T10:17:51.000+02:00
Add global_ param to basic_qos call in RobustChannel _on_open method
diff --git a/aio_pika/robust_channel.py b/aio_pika/robust_channel.py
@@ -143,6 +143,7 @@ async def _on_open(self) -> None:
         await channel.basic_qos(
             prefetch_count=self._prefetch_count,
             prefetch_size=self._prefetch_size,
+            global_=self._global_qos,
         )
 
         for exchange in exchanges:

Original file line number	Diff line number	Diff line change
`@@ -143,6 +143,7 @@ async def _on_open(self) -> None:`
`143`	`143`	`await channel.basic_qos(`
`144`	`144`	`prefetch_count=self._prefetch_count,`
`145`	`145`	`prefetch_size=self._prefetch_size,`
	`146`	`+ global_=self._global_qos,`
`146`	`147`	`)`
`147`	`148`
`148`	`149`	`for exchange in exchanges:`