You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
sorry, i didn't notice your message. that's right - tx hasn't been implemented yet. no specific reason. PR is welcome if anyone fancies 👍 The approach would be like:
Create records under core.ex for Tx class
Implement each functions under newly created AMQP.Tx module
I suppose you can pretty much follow the implementation of AMQP.Confirm.select/1.
I'm currently evaluating persistence guarantees if a RabbitMQ node fails and read about enabling transactional mode in channels.
However, I've not found any way to do this with this library. Am I missing something? Or is this not implemented yet?
(The other topic would be Publisher Confirms, but I guess that's something that's not covered by the AMQP standard?)
The text was updated successfully, but these errors were encountered: