AMQP транзакции с Kombu и Rabbitmq

Кажется, я не могу найти какую-либо документацию по использованию транзакций AMQP через API Kombu.
На этой странице говорится о добавлении сообщения в состояние транзакции, но оно не похоже на связанное.

Я знаю, что бэкэнд pika поддерживает их, и я вполне уверен, что бэкэнд amqplib (который я сейчас использую) тоже делает, но я пока не вижу, как это проявляется в Kombu.

Изменить: чтобы уточнить, я ищу channel.commit(), channel.select(), ... методы типа

Источник

1 ответ

Решение

Оказывается, что транзакции были специально не выставлены, поскольку они не так полезны, как я думал сначала. В частности, набор команд tx действителен только для одной очереди, и RabbitMQ с большой вероятностью полностью исключит поддержку класса tx.

Полное обсуждение можно найти в списке рассылки rabbitmq.

Источник
Другие вопросы по тегам