grabbit
grabbit copied to clipboard
wework
A lightweight transactional message bus on top of RabbitMQ
@vladshub @adiweiss @avigailberger @danielwitz @yuvmendel thoughts?
A way to manage message de-duplication in grabbit. Implementation details: * Each instance would set its own policy, it can be the default - None, reject duplicates - Reject and...
Solve issue #158 Disconnects rabbitmq and allows the addition of kafka or any other transport.
By default, grabbit correlates a message to the correct saga instance when a handler replies to an incoming message. There are many cases in which you would like to interact...
Collect and report operational metrics Candidate metrics - tx/s - outbox size - confirm rates - pending saga instances - confirm rates - saga timeout - health errors **Transactional Outbox...
Evaluate a more robust way of relaying messages from the outbox by using mysql binlog. the approach is described here: https://medium.com/@infinity.jacksparrow/how-to-deal-with-mysql-binlog-using-golang-with-examples-49c36124b105
the gbus.Builder interface has some methods that are not in use nor will be. need to delete them from the interface
The current implementation of the mysql saga store, when fetching saga instances by sage type, fetches all saved instances in one round trip which may cause a performance issue when...