From @asyncee on Thu May 17 2018 14:53:59 GMT+0000 (UTC)
Hello! Is it possible to implement at least once events delivery?
I have few microservices broadcasting domain events to event bus and if one of them goes down, them system can become to inconsistent state. Currently i have no idea how to fix this, because there are can be 0…N subscribers to any particular event.
So i thought that maybe it is possible that at-least-once-delivery for event messages can be implemented? For example, messages may be persisted in queue for some time until expiration timeout, or something like ReplaySubject (rxjava) may be implemented (it emits all the items of the source Observable, regardless of when the subscriber subscribes).
Or, maybe, there are already good practices to solve this problem exist?
Copied from original issue: https://github.com/nameko/nameko/issues/543