I am pseudo implementing http://crossbar.io/docs/Event-History/ but its two commit.
The docs show code for js and when I search github I do not find the method “wamp.subscription.lookup” anywhere in the repo. would prefer single point of failure be the message delivery system.
Mainly if I have subscribers that fail while messages are written they pick up on messages they have not yet processed.
Otherwise I imagine I have to abstract and:
Request -> Async method to write event to persistent store -> callback to crossbar -> reprocess if transport is down
Read from persistent store for potentially missed messages. This however ruins FIFO.