开发者

AMQP transactions with Kombu and Rabbitmq

开发者 https://www.devze.com 2023-03-16 00:30 出处:网络
I cant seem to find any documentation on using AMQP transactions through the Kombu api. This page talks about appending a message to the transactional state but it does not seem related.

I cant seem to find any documentation on using AMQP transactions through the Kombu api.

This page talks about appending a message to the transactional state but it does not seem related.

I know the pika backend supports them and I am quite sure the amqplib backend (which Im currently using) does too but I do开发者_StackOverflownt yet see how this is exposed in Kombu.

Edit: to clarify, Im looking for channel.commit(), channel.select(), ... type methods


Turns out that transactions were specifically not exposed as they are not as useful as I had thought at first. Specifically the tx set of commands are only valid across a single queue and RabbitMQ will very likely remove the support for the tx class altogether.

A full discussion can be found on the rabbitmq mailing list

0

精彩评论

暂无评论...
验证码 换一张
取 消

关注公众号