@Test void prepareForReplay_WillDropProjections() { pendingRegistrationsEventHandler.prepareForReplay(); verify(pendingRegistrationsRepository).deleteAll(); }
@ResetHandler public void prepareForReplay() { LOGGER.info("{} deleting projections", PendingRegistrationsEventHandler.class.getSimpleName()); pendingRegistrationsRepository.deleteAll(); }
PendingRegistrationsEventHandler implements ReplayCompletionAware { @ResetHandler public void prepareForReplay() { LOGGER.info("{} deleting projections", PendingRegistrationsEventHandler.class.getSimpleName()); pendingRegistrationsRepository.deleteAll(); } }
PendingRegistrationsEventHandler implements ReplayCompletionAware { @ResetHandler public void prepareForReplay() { LOGGER.info("{} deleting projections", PendingRegistrationsEventHandler.class.getSimpleName()); pendingRegistrationsRepository.deleteAll(); } PendingRegistrationsEventHandler(PendingRegistrationsRepository pendingRegistrationsRepository); }
PendingRegistrationsEventHandler implements ReplayCompletionAware { @ResetHandler public void prepareForReplay() { LOGGER.info("{} deleting projections", PendingRegistrationsEventHandler.class.getSimpleName()); pendingRegistrationsRepository.deleteAll(); } PendingRegistrationsEventHandler(PendingRegistrationsRepository pendingRegistrationsRepository); @ResetHandler void prepareForReplay(); }
PendingRegistrationsEventHandler implements ReplayCompletionAware { @ResetHandler public void prepareForReplay() { LOGGER.info("{} deleting projections", PendingRegistrationsEventHandler.class.getSimpleName()); pendingRegistrationsRepository.deleteAll(); } PendingRegistrationsEventHandler(PendingRegistrationsRepository pendingRegistrationsRepository); @ResetHandler void prepareForReplay();  }