pluto icon indicating copy to clipboard operation
pluto copied to clipboard

[MIST-1139] Integrate replaying upon recovery

Open kyungissac opened this issue 7 years ago • 0 comments

This PR resolves #1139 by :

  • Adding ReplayServerAddress and ReplayServerPort parameters
  • Modifying start method of QueryStarter class to startOrSetupForReplay because most of the code for both are the same
  • Adding replayAndStart method to QueryStarter class
  • Adding setup method for MqttDataGenerator class (subscribe but do not emit data. This is for at-least-once event emission.)
  • Modifying recoverGroup of checkpointManager class to handle setup and replay/start separately
  • Adding setupQueryWithCheckpoint to QueryManager class
  • Adding sendMsgs to EventReplayUtils for sending replay messages in chronological order

Closes #1139

kyungissac avatar May 25 '18 04:05 kyungissac