AMQP transactions with Kombu and Rabbitmq
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
精彩评论