我似乎找不到任何关于通过Kombu api使用AMQP 事务的文档。此页面讨论了将消息附加到事务状态,但似乎并不相关。
我知道 pika 后端支持它们,我很确定 amqplib 后端(我目前正在使用)也支持,但我还没有看到它是如何在 Kombu 中公开的。
编辑:澄清一下,我正在寻找 channel.commit()、channel.select()、... 类型方法
我似乎找不到任何关于通过Kombu api使用AMQP 事务的文档。此页面讨论了将消息附加到事务状态,但似乎并不相关。
我知道 pika 后端支持它们,我很确定 amqplib 后端(我目前正在使用)也支持,但我还没有看到它是如何在 Kombu 中公开的。
编辑:澄清一下,我正在寻找 channel.commit()、channel.select()、... 类型方法
事实证明,交易并没有特别公开,因为它们并不像我一开始想象的那么有用。具体来说,tx 命令集仅在单个队列中有效,并且 RabbitMQ 很可能会完全删除对 tx 类的支持。
完整的讨论可以在rabbitmq 邮件列表中找到