Tranzacții AMQP (txSelect/txCommit) în RabbitMQ în RabbitMQ

Publisher Confirms vs Tranzacții AMQP

Protocolul AMQP 0-9-1 include un mecanism nativ de tranzacții prin metodele tx_select, tx_commit și tx_rollback. Deși oferă garanții stricte de consistență atomică (toate mesajele publicate devin vizibile simultan), tranzacțiile AMQP sunt extrem de lente (reduc debitul cu până la 250x deoarece blochează firul de execuție la fiecare commit). În arhitecturile moderne se recomandă Publisher Confirms.

try:
    channel.tx_select() # Inițializare tranzacție
    channel.basic_publish(exchange='', routing_key='plati', body=b'Plata A')
    channel.basic_publish(exchange='', routing_key='facturi', body=b'Factura A')
    channel.tx_commit() # Salvare atomică pe broker
except Exception:
    channel.tx_rollback() # Anulare completă în caz de eroare