pluto
pluto copied to clipboard
[MIST-1139] Integrate replaying upon recovery
This PR resolves #1139 by :
- Adding
ReplayServerAddressandReplayServerPortparameters - Modifying
startmethod ofQueryStarterclass tostartOrSetupForReplaybecause most of the code for both are the same - Adding
replayAndStartmethod toQueryStarterclass - Adding
setupmethod forMqttDataGeneratorclass (subscribe but do not emit data. This is for at-least-once event emission.) - Modifying
recoverGroupofcheckpointManagerclass to handle setup and replay/start separately - Adding
setupQueryWithCheckpointtoQueryManagerclass - Adding
sendMsgstoEventReplayUtilsfor sending replay messages in chronological order
Closes #1139