RabbitMQ: Fix broken max_length_bytes typo

Flared · Jul 20, 2023 · cfa15ec · cfa15ec
1 parent 21130de
commit cfa15ec
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/saturn_engine/worker/topics/rabbitmq.py b/src/saturn_engine/worker/topics/rabbitmq.py
@@ -220,7 +220,7 @@ async def queue(self) -> aio_pika.abc.AbstractQueue:
         if self.options.max_length:
             arguments["x-max-length"] = self.options.max_length
         if self.options.max_length_bytes:
-            arguments["x-max-length-bytes"] = self.options.max_length
+            arguments["x-max-length-bytes"] = self.options.max_length_bytes
         arguments["x-overflow"] = self.options.overflow
 
         channel = await self.channel