Added a bunch of classes/grains that would facilitate a message replay
ability, essentially allowing a subscriber to ask for messages since a
certain point.
This is essential if we want a reconnect with best effort
for not missing any messages in the interim
Added a bunch of classes/grains that would facilitate a message replay ability, essentially allowing a subscriber to ask for messages since a certain point. This is essential if we want a reconnect with best effort for not missing any messages in the interim