Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[MIST-1139] Integrate replaying upon recovery #1140

Open
wants to merge 2 commits into
base: master
Choose a base branch
from

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