rhinof

Hi, I have added support for connecting to the broker with TLS by passing in a *tls.Config object. Hope this gets to master. Thanks Guy

Support Kafka as an additional transport

9

@vladshub @adiweiss @avigailberger @danielwitz @yuvmendel thoughts?

Allow saga's to override correlation logic.

1

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 processing outbox by parsing mysql binlog

1

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

Cleanup bus builder interface

1

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...

When Invoking the RPC interface from within a handler a reply is never received and the call times out and returns an error **To Reproduce** [https://gist.github.com/rhinof/90553bc2fa43aa8c33ad9c2704f95a6b](https://gist.github.com/rhinof/90553bc2fa43aa8c33ad9c2704f95a6b)