2

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

dgorissen
  • 6,207
  • 3
  • 43
  • 52
  • I had a brief look at the Kombu docs and cannot find anything related to AMQP transaction control. It may well be that it's just not supported by that wrapper library's API yet. I'll let others more familiar with it post an answer which is definitive. – Brian Kelly Jun 30 '11 at 01:55
  • @Brian Kelly: thanks, I agree. I have opened an issue: https://github.com/ask/kombu/issues/46 – dgorissen Jun 30 '11 at 07:40

1 Answers1

1

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

Community
  • 1
  • 1
dgorissen
  • 6,207
  • 3
  • 43
  • 52