Skip to content

Conversation

@kyungissac
Copy link
Contributor

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

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Integrate replaying upon recovery

1 participant