Search code examples
transactionsrabbitmqamqpkombupy-amqplib

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 dont yet see how this is exposed in Kombu.

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


Solution

  • 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