fix(rabbitmq): 修复消费循环启动时未设置to_tuple参数的问题

mic1on · mic1on · commit 11669e3565a6 · 2025-09-25T10:12:21.000+08:00
diff --git a/src/use_rabbitmq/__init__.py b/src/use_rabbitmq/__init__.py
@@ -389,7 +389,7 @@ def start_consuming(
                     **kwargs
                 )
                 # 启动消费循环
-                channel.start_consuming()
+                channel.start_consuming(to_tuple=False)
 
             except amqpstorm.AMQPChannelError as exc:
                 if self.__shutdown:

Original file line number	Diff line number	Diff line change
`@@ -389,7 +389,7 @@ def start_consuming(`
`389`	`389`	`**kwargs`
`390`	`390`	`)`
`391`	`391`	`# 启动消费循环`
`392`		`- channel.start_consuming()`
	`392`	`+ channel.start_consuming(to_tuple=False)`
`393`	`393`
`394`	`394`	`except amqpstorm.AMQPChannelError as exc:`
`395`	`395`	`if self.__shutdown:`