...
The current code reads from a custom message queue implemented in go language. This message queue itself is populated by messages retrieved from the event message bus. The proposal is to use redis database to store the events that could not be received by the subscriber. We will also need to store the forwarding info including destination info. The event service will then periodically check the DB for pending events and attempt to send the same. The interval shall be added a as configuration to ODIMRA. Alternatively a successful transmission can also trigger the forwarding of events pending in DB.
...